我试着用卡夫卡。 所有配置都正确完成，但当我试图从控制台产生消息时，我一直得到以下错误
WARN Error while fetching metadata with correlation id 39 :
{4-3-16-topic1=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
Kafka版本:2.11-0.9.0.0
当前回答
对于我来说，我没有为Kafka实例指定代理id。 当它在Docker环境中重启时，有时会从zookeeper获取一个新的id。 如果您的代理id大于1000，只需指定环境变量KAFKA_BROKER_ID。
使用它可以查看代理、主题和分区。
brew install kafkacat
kafkacat -b [kafka_ip]:[kafka_poot] -L
其他回答
当我们试图订阅一个尚未创建的主题时，我们往往会收到这条消息。我们通常依赖于在部署环境中预先创建的主题，但我们有针对dockerized kafka实例运行的组件测试，每次都干净启动。
在这种情况下，我们在测试设置中使用AdminUtils来检查主题是否存在，如果不存在就创建它。有关设置AdminUtils的更多信息，请参阅另一个堆栈溢出。
这可能与server.properties中的advertised.host.name设置有关。
可能发生的情况是，您的生产者试图找出谁是给定分区的领导者，找出它的advertised.host.name和advertised。端口并尝试连接。 如果这些设置没有正确配置，那么可能会认为领导者不可用。
上述答案中提到的广告听众可能是原因之一。其他可能的原因有:
主题可能还没有创建。你可以使用bin/kafka-topics——list——zookeeper <zookeeper ip>:<zookeeper port>来检查 检查您提供给生成器以获取元数据的引导服务器。如果引导服务器不包含关于主题的最新元数据(例如，当它丢失其zookeeper声明时)。您必须添加多个引导服务器。
另外，确保已将所发布的侦听器设置为IP:9092而不是localhost:9092。后者意味着只能通过本地主机访问代理。
当我遇到错误时，我记得在引导服务器(或代理列表)列表中使用了PLAINTEXT://<ip>:<PORT>，它工作了，奇怪的是。
bin/kafka-console-producer --topic sample --broker-list PLAINTEXT://<IP>:<PORT>
当LEADER_NOT_AVAILABLE错误抛出时，只需重新启动kafka代理:
/bin/kafka-server-stop.sh
紧随其后的是
/bin/kafka-server-start.sh config/server.properties
(注意:Zookeeper必须在这个时候运行，否则它不会工作)
如果你得到这样重复的错误消息:
Error while fetching metadata with correlation id 3991 : {your.topic=LEADER_NOT_AVAILABLE}
Or
Discovered group coordinator 172.25.1.2:9092 (id: 2147483645 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:677)
(Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:509)
Group coordinator 172.25.1.2:9092 (id: 2147483645 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:729)
Discovered group coordinator 172.25.40.219:9092 (id: 2147483645 rack: null) (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:677)
Group coordinator 172.25.1.2:9092 (id: 2147483645 rack: null) is unavailable or invalid, will attempt rediscovery (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:729)
然后，你需要像这样在kafka server.properties中配置监听器:
listeners=PLAINTEXT://your.server.ip:9092
这是在Kafka 2.5.0和confluent 5.4.1平台上尝试的解决方案。
