- kafka文件所在位置：
cd /UTMGMAPL/upkafka_1.2.11-1.0/bin
- 创建一个模拟生产者
./kafka-console-producer.sh --broker-list 146.33.240.13:9092 --topic topic_tyq_1
- 创建一个模拟消费者
./kafka-console-consumer.sh --bootstrap-server 146.33.20.14:9092 --topic topic_tyq_1
- 创建一个分区为1 ，副本数为1的topic，在broker_list集群中都能查到此topic
./kafka-topics.sh --zookeeper 146.33.240.14:22181 --create --replication-factor 1 --partitions 1 --topic topic_tyq
- 查看所有已存在的topic
./kafka-topics.sh --zookeeper 146.33.240.14:22181 --list
- 查看所有topic信息
./kafka-topics.sh --zookeeper 146.33.240.14:22181 --describe
- 查看指定topic的信息
./kafka-topics.sh --zookeeper 146.33.240.14:22181 --describe --topic topic_tyq
- 修改topic分区数量(只能增加分区数量)
./kafka-topics.sh --zookeeper 146.33.240.14:22181 --alter --topic topic_tyq --partions 3
- 创建指定分组的消费者，这样启动起来多个消费者都指定成一个组里面到了，那么多分区时就会被分别消费了，如果组中的消费者数量多于分区数，多余出来的消费者将消费不到数据
./kafka-console-consumer.sh --bootstrap-server 146.33.240.14:9092 --topic topic_tyq --consumer-property group.id=group1
- 删除topic（没有彻底删除，不可见）
./kafka-topics.sh --zookeeper 146.33.240.14:22181 --delete --topic topic_tyq