-
Notifications
You must be signed in to change notification settings - Fork 13.9k
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
KAFKA-7449 Forward topic from console consumer to deserializer #5704
Conversation
LGTM |
LGTM. Does it need a test? ConsoleConsumerTest should be a suitable place. |
Yes, a test would be good. |
cb6e3d3
to
db6be73
Compare
Done (sorry for the delay). |
400608b
to
6b0b521
Compare
I don't realy understand why the build on JDK 11 with Scala 2.12 is ending in timeout. |
6b0b521
to
e1d1c96
Compare
Some deserializer needs the topic name to be able to correctly deserialize the payload of the message. Console consumer works great with Deserializer<String> however it calls deserializer with topic set as null. This breaks the API and the topic information is available in the ConsumerRecord.
e1d1c96
to
5e17a49
Compare
Hmm not sure why the test is being skipped for the JDK 8 build, lets have Jenkins rerun the tests. |
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.
@mchataigner : Thanks for the patch. LGTM
Some deserializer needs the topic name to be able to correctly deserialize the payload of the message. Console consumer works great with Deserializer<String> however it calls deserializer with topic set as null. This breaks the API and the topic information is available in the ConsumerRecord. Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com>, Chia-Ping Tsai <chia7712@gmail.com>, Gardner Vickers <gardner@vickers.me>, Jun Rao <junrao@gmail.com>
Some deserializer needs the topic name to be able to correctly deserialize the payload of the message.
Console consumer works great with Deserializer however it calls deserializer with topic set as null.
This breaks the API and the topic information is available in the ConsumerRecord.
More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.
Summary of testing strategy (including rationale)
for the feature or bug fix. Unit and/or integration
tests are expected for any behaviour change and
system tests should be considered for larger changes.
Committer Checklist (excluded from commit message)