THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
> kafka-transactions.sh --find-hanging --broker 0 --bootstrap-server localhost:9092 Topic Partition ProducerId ProducerEpoch StartOffset LastTimestamp Duration(s) foo 0 134132 23 550 15983835372020-09-17T23:02:23Z 3000030 # Limit the search to a specific topic partition > kafka-transactions.sh --find-hanging --broker 0 --topic foo --partition 0 --bootstrap-server localhost:9092 Topic Partition ProducerId ProducerEpoch StartOffset LastTimestamp Duration(s) foo 0 134132 23 550 15983835372020-09-17T23:02:23Z 30000 |
Describing Transactions
...
Code Block |
---|
# Describe producers on the leader of a topic partition > kafka-transaction.sh --describe-producers --topic foo --partition 0 --bootstrap-server localhost:9092 ProducerId ProducerEpoch StartOffset LastTimestamp Duration(s) CoordinatorEpoch 134132 23 550 15983835372020-09-17T23:02:23Z 3000030 77 134938 5 439 15983835672020-09-17T23:01:23Z 2997090 64 # Describe producers for a specific replica of a topic partition > kafka-transaction.sh --describe-producers --broker 0 --topic foo --partition 0 --bootstrap-server localhost:9092 ProducerId ProducerEpoch StartOffset LastTimestamp Duration(s) CoordinatorEpoch 134132 23 550 15983835372020-09-17T23:02:23Z 3000030 77 134938 5 439 15983835672020-09-17T23:01:23Z 2997090 64 |
Aborting Transactions
The --abort command can be used to abort an ongoing transaction for a topic partition. It has several required arguments:
...