关于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宕机了。还能发送消息吗?
1、9.0版本之后,就只需要broker端口了,不需要配置zookeeper了。0。8版本的时候,发布消息直接对接broker,所以是9092,消费的时候,需要通过zookeeper去负载,固是2181.
2、通过逗号分隔
3、发布消息不知道哪个可用?不明白
broker需要全部指定吗?9092,9093,9094
还是任意指定一个就行?9092
broker-list localhost:9092
按照事例,这里指定localhost:9093也是可以的吗?
不需要全部指定,他们通过其中一条broker获取到集群所有的metadata。
是可以的。只要是集群中的一台都是可以的。
你的答案