You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Federico Valeri (Jira)" <ji...@apache.org> on 2026/06/18 10:05:00 UTC
[jira] [Created] (KAFKA-20712) TransactionLogMessageFormatter and TransactionLogMessageParser output numeric transactionStatus instead of state name
Federico Valeri created KAFKA-20712:
---------------------------------------
Summary: TransactionLogMessageFormatter and TransactionLogMessageParser output numeric transactionStatus instead of state name
Key: KAFKA-20712
URL: https://issues.apache.org/jira/browse/KAFKA-20712
Project: Kafka
Issue Type: Bug
Components: tools
Affects Versions: 4.0.0
Reporter: Federico Valeri
Assignee: Federico Valeri
After KAFKA-18616 refactored the TransactionLogMessageFormatter to extend CoordinatorRecordMessageFormatter (commit b6adec48c5), the transactionStatus field in the decoded output is rendered as its raw int8 value (e.g., 4) instead of the human readable state name (e.g., CompleteCommit).
This affects both:
- kafka-dump-log.sh --transaction-log-decoder (which uses TransactionLogMessageParser in DumpLogSegments)
- kafka-console-consumer.sh with TransactionLogMessageFormatter
The root cause is that the auto generated TransactionLogValueJsonConverter.write() serializes the transactionStatus byte field as new ShortNode(_object.transactionStatus). It has no knowledge of the TransactionState enum, so the numeric ID is emitted as is.
Before the refactor, the formatter used a hand written implementation that was also emitting the raw byte. However, the old Scala TransactionLog.valueToString() (used prior to KAFKA-16666) did resolve the byte to the state name. When the Java migration was done in KAFKA-16666 the state name resolution was lost, but the problem only became visible now because the output format changed.
Steps to reproduce:
{noformat}
bin/kafka-dump-log.sh --deep-iteration --print-data-log
--transaction-log-decoder
--files /tmp/kafka-logs/__transaction_state-0/00000000000000000000.log
{noformat}
Expected output (field excerpt):
{noformat}
"transactionStatus":"CompleteCommit"
{noformat}
Actual output:
{noformat}
"transactionStatus":4
{noformat}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)