Kafka의 _transaction_state 주제에서 데이터 읽기 0.11.0.1

Question

특정 트랜잭션 ID에 대한 트랜잭션이 커밋되었는지 또는 트랜잭션 ID에 대한 트랜잭션이 커밋 되었는가를 파악할 수 있도록 트랜잭션에 대한 메타 데이터 (Kafka 0.11.0.1에서 지원됨)를 읽으 려합니다. 아니. 현재 _transactional_state 주제에서 키와 값을 얻고 있지만 인코딩 된 형식입니다. 키 = 10000000mmm, 값 = ���� + ') 당신은 TransactionLogMessageParser의 소스 코드를 볼 수

Answer 1

: 다음은 내가 __transaction_state 주제를 폴링 할 때 내가받은 일부 동일한 키/값입니다 예를 들어 kafka/tools/DumpLogSegments.scala 파일 내부에 있습니다. TransactionLog 클래스의 readTxnRecordValue 함수를 사용합니다. 이 함수의 첫 번째 인수는 동일한 클래스의 readTxnRecordKey 함수를 통해 검색 할 수 있습니다.