我使用spotify/kafka映像在ec2上的docker容器中运行kafka。
我用下面的命令启动了Kafka:
docker run --name kafka -i -t -p 2181:2181 -p 9092:9092 --env ADVERTISED_HOST=kafka -h kafka --env ADVERTISED_PORT=9092 spotify/kafka
在docker容器中发布和使用消息可以很好地工作,但是当我发布来自另一个ec2示例的消息时就不起作用了。
下面是我用来向主题发布消息的命令:
./kafka-console-producer.sh --broker-list docker_host_ip:9092 --topic test-topic
以下是错误消息:
[2018-04-19 22:14:30,231] WARN [Producer clientId=console-producer] Error while fetching metadata with correlation id 2 : {test-topic=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
有人在容器内远程发布了关于kakfa主题的消息吗?
暂无答案!
目前还没有任何答案,快来回答吧!