Commands

topic

# 查看 topic 列表
kafka-topics.sh --zookeeper 127.0.0.1:2181 --list
# 创建 topic
kafka-topics.sh --zookeeper 127.0.0.1:2181 --create --topic name_of_topic --replication-factor 2 --partitions 3

group

# 查看组消息
kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --describe --group name_of_group

发送消息

# 进入生产者控制台
kafka-console-producer.sh --topic trailer_express_tracking --broker-list 172.16.0.110:9092
# 发送消息
> Hello world