apache-kafka - 从 Kafka 0.11.0.1 中的 _transaction_state 主题读取数据

Question

我想读取事务的元数据(Kafka 0.11.0.1 支持)，以便我可以确定特定事务 ID 的事务是否已提交。目前我正在从 _transactional_state 主题获取键和值，但它采用某种编码格式。
以下是我在轮询 __transaction_state 主题时收到的一些相同的键/值:
键 = 10000000mmm，值 = � � ���� +'����������)

Answer 1

您可以查看 TransactionLogMessageParser 的源代码类内kafka/tools/DumpLogSegments.scala文件为例。它使用 readTxnRecordValue函数来自 TransactionLog类(class)。此函数的第一个参数可以通过 readTxnRecordKey 检索。同一个类的功能。