Kafka 學習筆記之 Kafka0.11之console-producer/console-consumer
Kafka 學習筆記之 Kafka0.11之console-producer/console-consumer:
啟動Zookeeper
啟動Kafka0.11
創建一個新的Topic:
./kafka-topics.sh --create --zookeeper hadoop1:2181,hadoop2:2181,hadoop3:2181 --replication-factor 1 --partitions 3 --topic Topic011
查詢Topic列表:
./kafka-topics.sh --list --zookeeper hadoop1:2181,hadoop2:2181,hadoop3:2181
查看Topic詳細信息:
./kafka-topics.sh --describe --zookeeper hadoop1:2181,hadoop2:2181,hadoop3:2181 --topic Topic011
建立訂閱者console-consumer:(Note:在0.9版本指定的是zookeeper server,0.11變成了broker server)
./kafka-console-consumer.sh --bootstrap-server hadoop1:9092,hadoop2:9092,hadoop3:9092 --topic Topic011
建立發布者console-producer:
./kafka-console-producer.sh --broker-list hadoop1:9092,hadoop2:9092,hadoop3:9092 --topic Topic011
發送消息:
Kafka 學習筆記之 Kafka0.11之console-producer/console-consumer