カフカの_transaction_stateトピックからデータを読み取る0.11.0.1

Question

特定のトランザクションIDのトランザクションがコミットされたかどうかを知るために、トランザクションのメタデータ（Kafka 0.11.0.1でサポートされている）を読みたいない。現在、_transactional_stateトピックからキーと値を取得していますが、エンコードされた形式です。 キー= 10000000mmm、値= ���� + '）あなたはTransactionLogMessageParserのソースコードに見ることができ

Answer 1

： 以下は、私が__transaction_stateトピックをポーリングするとき、私は受け取ったいくつかの同じキー/値ですクラス内にkafka/tools/DumpLogSegments.scalaファイルを例として示します。それはTransactionLogクラスのreadTxnRecordValue関数を使用します。この関数の最初の引数は、同じクラスの関数readTxnRecordKeyで取得できます。