1.查看topic列表
./kafka-topics.sh --zookeeper localhost:2181 --list
2.创建一个名为test的topic
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
--replication-factor 表示 kafka保存消息的副本数
--partitions 该参数指定了新创建的主题需要包含多少个分区
3.创建一个消费者并且关注名称为test的topic
./kafka-console-consumer.sh --bootstrap-server IP:9092 --topic test --from-beginning
./kafka-console-consumer.sh --bootstrap-server IP:9092 --topic test --from-beginning --consumer.config ../config/client-sasl.properties
--consumer.config 指定消费者使用的配置文件
4.创建一个生产者并关注名称为test的topic
./kafka-console-producer.sh --broker-list IP:9092 --topic test
./kafka-console-producer.sh --broker-list IP:9092 --topic test --producer.config ../config/client-sasl.properties
--producer.config 指定生产者使用的配置文件
5.查看某个topic下的内容
./kafka-run-class.sh kafka.tools.DumpLogSegments --files XXX.log --print-data-log
XXX.log为要查看的topic物理存储的绝对路径加文件名