1碑宴、創(chuàng)建topic
./bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic first --partitions 1 --replication-factor 1
./bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 3 --partitions 1 --topic first1
config cleanup.policy包含delete/compact
./bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 3 --partitions 12 --topic first2 --config delete.retention.ms=86400000 --config cleanup.policy=compact
2亲桥、查詢topic刊头，進入kafka目錄：bin/kafka-topics.sh --list --zookeeper localhost:2181
3饿这、查詢topic./bin/kafka-topics.sh --list --bootstrap-server localhost:9092
4、查詢topic內(nèi)容：bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic first --from-beginning
5、查看topic 為 first的 詳細信息./bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic first
返回的信息如下
Topic:first PartitionCount:1 ReplicationFactor:1 Configs:segment.bytes=1073741824
Topic: first Partition: 0 Leader: 1 Replicas: 1 Isr: 1
6、往topic 為 first 的內(nèi)部生產(chǎn)消息./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic first
輸入以下九條數(shù)據(jù)（包含空格）
nihao
nihao
你好
quit
exit
?
實時消費的
7舶治、從topic 為first的內(nèi)部消費消息，此時打開消費就能收到實時發(fā)送的消息了./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic first
8车猬、查詢當前topic某分區(qū)中數(shù)據(jù)的偏移量信息霉猛，注： time為-1時表示最大值，time為-2時表示最小值（可查看到包含9條數(shù)據(jù)信息）
./bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic first --time -1 --partitions 0
返回的信息
first:0:9
9珠闰、從指定的分區(qū)--partition 0惜浅，指定偏移量—offset 5，最大消息輸出--max-messages 5（當接收夠五條就會關(guān)閉接收請求伏嗜，不設(shè)置次選項就會一直接受）查詢當前topic信息
./bin/kafka-console-consumer.sh? --bootstrap-server localhost:9092 --topic first --partition 0 --offset 5 --max-messages 5 --property? print.timestamp=true
CreateTime:1684392637695 quit
CreateTime:1684392641949 exit
CreateTime:1684392913335 ?
CreateTime:1684392923551 實時消費的
