我想读取事务的元数据（Kafka 0.11.0.1 支持），以便确定特定事务 ID 的事务是否已提交。目前我正在从 _transactional_state 主题中获取键和值，但它是某种编码格式。以下是我在轮询 __transaction_state 主题时收到的一些相同的键/值：key = 10000000mmm, value = � ���<code>����+'���������)
问问题
1264 次
2 回答
4
您可以查看文件TransactionLogMessageParser内部类的源代码kafka/tools/DumpLogSegments.scala作为示例。它使用类中的readTxnRecordValue函数TransactionLog。该函数的第一个参数可以通过readTxnRecordKey同一类的函数检索。
于 2017-12-06T10:25:17.843 回答
3
就像在 Kafka 中所做的一样，如何从 __consumer_offsets 主题中读取
echo "exclude.internal.topics=false" > consumer.config
kafka-console-consumer --consumer.config consumer.config --formatter "kafka.coordinator.transaction.TransactionLog\$TransactionLogMessageFormatter" --bootstrap-server localhost:9092 --topic __transaction_state --from-beginning
于 2019-04-25T14:14:30.753 回答