【创建Topic】
kafka-topics.sh --create --topic testtopic --zookeeper 127.0.0.1:2181 --config max.message.bytes=12800000 --config flush.messages=1 --partitions 3 --replication-factor 2
--config  指定当前topic上有效的参数值
--partitions  指定topic的分区数量，默认是server.properties中的num.partitions值
--replication-factor  指定每个分区的副本个数，默认1个

【查看所有Topic】
kafka-topics.sh --list --zookeeper 127.0.0.1:2181
【查看指定Topic的分区和副本】
kafka-topics.sh --describe --zookeeper 127.0.0.1:2181  --topic testtopic

【删除topic】
#删除指定topic命令
kafka-topics.sh --delete --zookeeper 127.0.0.1:2181 --topic testtopic
#删除zookeeper中指定topic相关目录的命令
rm -r /kafka/config/topics/testtopic
rm -r /kafka/brokers/topics/testtopic

【查看topic消费的offset偏移量】
kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 127.0.0.1:9092 --topic testtopic --time -1

【修改topic的partition数量，只能增加不能减少】
kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group testgroup --topic testtopic --zookeeper 127.0.0.1:2181

【启动kafka生产者】
kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic testtopic

【启动kafka消费者】
#从头开始消费
kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic testtopic --from-beginning
#从尾部开始消费
kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic testtopic --offset latest
#指定分区消费
kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic testtopic --offset latest --partition 1
#取指定个数的消息
kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic testtopic --offset latest --partition 1 --max-messages 1

【消费者组】
查看所有消费者Group
kafka-consumer-groups.sh --new-consumer --bootstrap-server 127.0.0.1:9092 --list
查看消费者Group详情
kafka-consumer-groups.sh --new-consumer --bootstrap-server 127.0.0.1:9092 --group testgroup --describe
删除消费者Group
kafka-consumer-groups.sh --new-consumer --bootstrap-server 127.0.0.1:9092 --group testestgroupt --delete