谢谢大家的帮助，我的项目已经成功地与Kafka集成了。在测试的时候，我遇到了一个问题，我需要一些帮助。我的制作人和消费者都指向Kafka经纪人说kb-1。我有一个复制因子为1.kb-1的代理群集由于某些内部原因而死亡，因此我们将生产者和消费者的ip切换到同一群集kb-2的另一个代理。使用所有数据并处理必要的警报是有效的，但是当我试图通过引导服务器中的kb-2 ip的producer生成数据时，它未能生成，并给出以下错误：org.apache.kafka.common.errors.timeoutexception请尽可能解释单点故障。谢谢你的帮助。