关于kafka发布和消息需要指定的参数问题

江湖浪子 发表于: 2016-05-14   最后更新时间: 2016-05-14 16:52:47   5,691 游览

关于kafka发布和消息需要指定的参数问题


我在 https://www.orchome.com/6 这一章使用的时候。通过以下命令

> bin/kafka-console-producer.sh --broker-list localhost:9092 
> bin/kafka-console-consumer.sh --zookeeper localhost:2181


1、为什么发布和消费指定的是不同的服务器和端口?

   发布消息需要指定broker-list:9092
   接收消息却是zookeeper的2181


2、broker-list可以指定多个吗?比如文章里的9093,9094.


3、发布消息不知道哪个——broker可用,怎么办?或者说上面指定9092宕机了。还能发送消息吗?

发表于 2016-05-14
添加评论

1、9.0版本之后,就只需要broker端口了,不需要配置zookeeper了。0。8版本的时候,发布消息直接对接broker,所以是9092,消费的时候,需要通过zookeeper去负载,固是2181.
2、通过逗号分隔
3、发布消息不知道哪个可用?不明白

江湖浪子 -> 無名 8年前

broker需要全部指定吗?9092,9093,9094
还是任意指定一个就行?9092

江湖浪子 -> 無名 8年前

broker-list localhost:9092

按照事例,这里指定localhost:9093也是可以的吗?

無名 -> 江湖浪子 8年前

不需要全部指定,他们通过其中一条broker获取到集群所有的metadata。

無名 -> 江湖浪子 8年前

是可以的。只要是集群中的一台都是可以的。

你的答案

查看kafka相关的其他问题或提一个您自己的问题