創(chuàng)建topic
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 12 --topic test_topic
查看消費組消費情況
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group test_group
發(fā)送消息
./kafka-console-producer.sh --broker-list localhost:9092 --topic test_topic