GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/987
MINOR: DefaultMessageFormatter custom deserializer fixes
The ability to specify a deserializer for keys and values was added in a
recent commit (845c6eae1f6c6bcf11), but it contained a few issues.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka console-consumer-cleanups
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/987.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #987
----
commit 06b5beedb7c9baa9e76a726a523e1218073f20fc
Author: Ismael Juma <[email protected]>
Date: 2016-02-29T22:54:15Z
Remove `println` that were merged to trunk by mistake
commit a48db9f8abcad1c5121b26bf43212252f0d81c12
Author: Ismael Juma <[email protected]>
Date: 2016-02-29T22:56:07Z
Change `key.decoder` to `key.deserializer` and `value.decoder` to
`value.deserializer`
This makes it consistent with the new consumer.
commit 29ead51aafbd25fca280a38ea0418c2465b4a33c
Author: Ismael Juma <[email protected]>
Date: 2016-02-29T23:42:56Z
Handle case where user doesn't provide deserializer correctly
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
