2. 使用
创建一个topic
Let's create a topic named "test" with a single partition and only one replica:
bin/kafka-topics.sh --create --zookeeper 192.168.111.111:2181 --replication-factor 1 --partitions 1 --topic test
We can now see that topic if we run the list topic command:
> bin/kafka-topics.sh --list --zookeeper localhost:2181
test
生产者
bin/kafka-console-producer.sh --broker-list 192.168.111.111:9092 --topic test
消费者
bin/kafka-console-consumer.sh --bootstrap-server 192.168.111.111:9092 --topic test --from-beginning
创建
bin/kafka-topics.sh --create --zookeeper 192.168.111.111:2181,192.168.111.112:2181,192.168.111.113:2181 --replication-factor 3 --partitions 1 --topic asdasd
删除
bin/kafka-topics.sh --delete --zookeeper 192.168.111.111:2181,192.168.111.112:2181,192.168.111.113:2181 --topic asdasd
查看
bin/kafka-topics.sh --describe --zookeeper 192.168.111.111:2181,192.168.111.112:2181,192.168.111.113:2181 --topic asdasd