kafka command

root@ip-10-0-56-54:~# /usr/local/kafka_2.13-3.4.1/bin/kafka-dump-log.sh –files /asyncmq/kafka/data3/asyncmq_local_us_kafka_cluster_01_29bb15a7-339e-3c4d-b559-5f39214c250b-0/00000000000004353579.index  –print-data-log|more
Dumping /asyncmq/kafka/data3/asyncmq_local_us_kafka_cluster_01_29bb15a7-339e-3c4d-b559-5f39214c250b-0/00000000000004353579.index
offset: 4353580 position: 34112
offset: 4353581 position: 70021
offset: 4353582 position: 104109
offset: 4353583 position: 138180
offset: 4353584 position: 172201
offset: 4353585 position: 207647
offset: 4353586 position: 241803

/usr/local/kafka_2.13-3.4.1/bin/kafka-dump-log.sh –files /asyncmq/kafka/data3/asyncmq_local_us_kafka_cluster_01_29bb15a7-339e-3c4d-b559-5f39214c250b-0/00000000000004167765.log –print-data-log

baseOffset: 2816434 lastOffset: 2816434 count: 1 baseSequence: 0 lastSequence: 0 producerId: -1 producerEpoch: -1 partitionLeaderEpoch: 4 isTransactional: false isControl: false deleteHorizonMs: OptionalLong.empty position: 0 LogAppendTime: 1696861264970 size: 1242 magic: 2 compre
sscodec: none crc: 3906560868 isvalid: true
| offset: 2816434 LogAppendTime: 1696861264970 keySize: 36 valueSize: 1136 sequence: 0 headerKeys: [] key: 317654a5-5ff3-4b22-acef-624ee1d5f2c3 payload: {“XXXXX”}

baseOffset: 2816435 lastOffset: 2816435 count: 1 baseSequence: -1 lastSequence: -1 producerId: -1 producerEpoch: -1 partitionLeaderEpoch: 4 isTransactional: false isControl: false deleteHorizonMs: OptionalLong.empty position: 1242 LogAppendTime: 1696861264989 size: 1408 magic: 2 c
ompresscodec: none crc: 500155102 isvalid: true
| offset: 2816435 LogAppendTime: 1696861264989 keySize: 36 valueSize: 1302 sequence: -1 headerKeys: [] key: 3b93459a-adb3-4ab9-8377-db087a233666 payload: {“XXXXX”}

 

root@ip-10-0-56-54:~# /usr/local/kafka_2.13-3.4.1/bin/kafka-dump-log.sh –files /asyncmq/kafka/data3/asyncmq_local_us_kafka_cluster_01_29bb15a7-339e-3c4d-b559-5f39214c250b-0/00000000000004322573.timeindex –print-data-log |more
Dumping /asyncmq/kafka/data3/asyncmq_local_us_kafka_cluster_01_29bb15a7-339e-3c4d-b559-5f39214c250b-0/00000000000004322573.timeindex
timestamp: 1697055992377 offset: 4322574
timestamp: 1697055992406 offset: 4322576
timestamp: 1697055992448 offset: 4322577
timestamp: 1697055992455 offset: 4322578
timestamp: 1697055992480 offset: 4322579
timestamp: 1697055992488 offset: 4322580

发布者

傅, 健

程序员,Java、C++、开源爱好者. About me