我试着用卡夫卡。 所有配置都正确完成，但当我试图从控制台产生消息时，我一直得到以下错误
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
当前回答
我解决这个问题的方法是这样设置监听器:
advertised.listeners = PLAINTEXT://my.public.ip:9092
listeners = PLAINTEXT://0.0.0.0:9092
这使得KAFKA代理侦听所有接口。
其他回答
加上这个，因为它可能会帮助其他人。一个常见的问题可能是advertised.host.name配置错误。在Docker中，使用Docker -compose设置KAFKA_ADVERTISED_HOST_NAME中的服务名称将不起作用，除非你也设置了主机名。docker-compose。yml例子:
kafka:
image: wurstmeister/kafka
ports:
- "9092:9092"
hostname: kafka
environment:
KAFKA_ADVERTISED_HOST_NAME: kafka
KAFKA_CREATE_TOPICS: "test:1:1"
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
volumes:
- /var/run/docker.sock:/var/run/docker.sock
上面没有hostname: kafka可以在尝试连接时发出一个LEADER_NOT_AVAILABLE。 您可以在这里找到一个工作docker-compose配置的示例
我尝试了这里列出的所有建议。对我有用的是去服务器。属性和添加:
port = 9092
advertised.host.name = localhost
将监听器和advertised_listeners注释掉。
在服务器上添加侦听器设置后，问题得到解决。属性文件位于配置目录。 listener =PLAINTEXT://localhost(或您的服务器):9092 修改完成后重新启动kafka。使用版本2.11
这个警告(在0.10.2.1中)的另一种可能是，你试图对一个刚刚创建的主题进行投票，而这个主题分区的领导者还不可用，你正在进行领导者选举。
在主题创建和轮询之间等待一秒钟是一种变通方法。
因为我想让我的kafka代理连接到远程生产者和消费者，所以我不想做广告。要注释掉的侦听器。在我的情况下，(在kubernetes上运行kafka)，我发现我的kafka pod没有分配任何集群IP。通过从服务中删除行clusterIP: None。呵呵，kubernetes给kafka pod分配了一个内部ip。这解决了我的LEADER_NOT_AVAILABLE问题，也解决了kafka生产者/消费者的远程连接问题。
