kafka-5-經常使用命令

kafka 經常使用命令

1. 建立topic

   bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 3 --partitions 1 --topic my-replicated-topic --config message.timestamp.type=CreateTime

   --config 能夠指定topic的配置，message.timestamp.type 指定topic的時間戳使用方式，其餘配置見

   https://kafka.apache.org/docu...

2. 查看topic狀態

   bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic my-replicated-topic

3. 生產者

   bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my-replicated-topic

4. 消費者

   bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic my-replicated-topic

5. 查看segment文件信息

   kafka-run-class.sh kafka.tools.DumpLogSegments --print-data-log --files xxxxxxxxxxxx.log