-
Notifications
You must be signed in to change notification settings - Fork 552
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
offline_log_viewer: fix get_control_record_type #18246
Conversation
@@ -82,7 +90,7 @@ def decode_record(batch, header, record): | |||
is_ctrl = attrs["control_batch"] | |||
is_tx_ctrl = is_txn and is_ctrl | |||
if is_tx_ctrl: | |||
record_dict["type"] = self.get_control_record_type(record.key) | |||
record_dict["type"] = get_control_record_type(record.key) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
did you also want to remove the duplicate function get_control_record_type
in KafkaLog
below?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
yikes.. I swear I removed it, maybe forgot to commit those changes.. anyway fixed it..
Also added a little regression test for future, had to adjust printing logic to print a wellformed json to stdout.
Noticed this was broken while parsing some logs. Added a little regression test for the parsing
will re-request reviews once tests pass.. these OLV script changes usually break existing tests |
Failure |
/backport v24.1.x |
/backport v23.3.x |
Noticed this was broken while parsing some logs.
Backports Required
Release Notes