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

Question

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

\n

Answer 1

就像 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