GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1385
[FLINK-3045] Properly expose the key of a Kafka message
The current Kafka connector does not allow users to access the message key.
With this change, I've added a new pair of serialization schemas
(`KeyedDeserializationSchema` and `KeyedSerializationSchema`) a utiliy to
create Kafka serializers from Flink's TypeInformation system:
`TypeInformationKeyValueSerializationSchema`.
I tried to make this change not API breaking.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmetzger/flink kafka_kv
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1385.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 #1385
----
commit f4709fe83c554a471a4f6df90c8e9f73781379e1
Author: Robert Metzger <[email protected]>
Date: 2015-11-19T14:41:01Z
[FLINK-3045] Properly expose the key of a Kafka message
commit 671c3792354e75a61b48042dbcb4c41e13aaf518
Author: Robert Metzger <[email protected]>
Date: 2015-11-19T14:52:57Z
wip
----
---
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.
---
