Kafka命令-生产者-消费者

 查看当前服务器中的所有 topic
bin/kafka-topics.sh --list --zookeeper zk01:2181
 创建 topic
bin/kafka-topics.sh --create --zookeeper zk01:2181 --replication-factor 1 --partitions 1 --topic test
 删除 topic
bin/kafka-topics.sh --delete --zookeeper zk01:2181 --topic test
需要 server.properties 中设置 delete.topic.enable=true 否则只是标记删除或者直接重启。
 通过 shell 命令发送消息
bin/kafka-console-producer.sh --broker-list kafka01:9092 --topic test
 通过 shell 消费消息
bin/kafka-console-consumer.sh --zookeeper zk01:2181 --from-beginning --topic test
 查看消费位置
bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper zk01:2181 --group testGroup
 查看某个 Topic 的详情
bin/kafka-topics.sh --topic test --describe --zookeeper zk01:2181
 对分区数进行修改
bin/kafka-topics.sh --zookeeper zk01 --alter --partitions 2 --topic test