从经纪人那里消费卡夫卡?
Consume kafka from brokers?
./bin/kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic test
./bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test
为什么消费kafka需要zookeeper?
我可以从经纪人那里消费卡夫卡吗?
--zookeeper
是一个过时的选项(对于旧消费者)。
将较新的 --bootstrap-server
选项与 kafka-console-consumer
结合使用。
更多信息:http://kafka.apache.org/documentation/#newconsumerconfigs
./bin/kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic test
./bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test
为什么消费kafka需要zookeeper? 我可以从经纪人那里消费卡夫卡吗?
--zookeeper
是一个过时的选项(对于旧消费者)。
将较新的 --bootstrap-server
选项与 kafka-console-consumer
结合使用。
更多信息:http://kafka.apache.org/documentation/#newconsumerconfigs