我正在尝试将Apache Kafka设置为在同一网络上运行CentOS的两个虚拟机之间进行通信。我最初在一台机器上设置了一个Kafka生产者和消费者,一切都很顺利。然后我在另一台机器上设置了Kafka,在尝试让它们连接的过程中,我得到了错误消息"bootstrap-server is not a recognized“(我正在运行最新版本的Kafka,2.2)。这是我用来尝试生产者连接的方法:
bin
我试图为Kafka主题创建一个自定义的主题策略。我发现在代理启动时调用了构造函数和configure()方法。但是,只要通过kafka-topics.sh工具创建了新主题,就不会调用validate()方法。import org.apache.kafka.common.errors.*;import java.util.*;came to policy