[
https://issues.apache.org/jira/browse/FLINK-3045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15015628#comment-15015628
]
ASF GitHub Bot commented on FLINK-3045:
---------------------------------------
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1385#issuecomment-158366729
Looks quite good.
I was wondering whether the KeyedSerializationSchema should have two
methods, one to serialize key, one to serialize the value. That way one does
not need this Tuple2 charade, and it looks more natural to Scala users as
well...
> Properly expose the key of a kafka message
> ------------------------------------------
>
> Key: FLINK-3045
> URL: https://issues.apache.org/jira/browse/FLINK-3045
> Project: Flink
> Issue Type: Improvement
> Components: Kafka Connector
> Reporter: Robert Metzger
> Assignee: Robert Metzger
> Priority: Critical
>
> Currently, the {{flink-kafka-connector}} is not properly exposing the message
> key.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
