[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16583406#comment-16583406
]
ASF GitHub Bot commented on FLINK-8500:
---------------------------------------
tzulitai commented on a change in pull request #6105: [FLINK-8500] Get the
timestamp of the Kafka message from kafka consumer
URL: https://github.com/apache/flink/pull/6105#discussion_r210809870
##########
File path: docs/dev/connectors/kafka.md
##########
@@ -153,7 +153,10 @@ produced Java/Scala type to Flink's type system. Users
that implement a vanilla
to implement the `getProducedType(...)` method themselves.
For accessing both the key and value of the Kafka message, the
`KeyedDeserializationSchema` has
-the following deserialize method ` T deserialize(byte[] messageKey, byte[]
message, String topic, int partition, long offset)`.
+the following deserialize methods ` T deserialize(byte[] messageKey, byte[]
message, String topic, int partition, long offset)` and
+` T deserialize(byte[] messageKey, byte[] message, String topic, int
partition, long offset, long timestamp, TimestampType timestampType)`.
+The first exists for backward compatibility reasons, for kafka 0.10+ consumers
the second is preferred because it
+also gives access to the kafka timestamp.
Review comment:
Capital 'k' for Kafka
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)
> ---------------------------------------------------------------------------
>
> Key: FLINK-8500
> URL: https://issues.apache.org/jira/browse/FLINK-8500
> Project: Flink
> Issue Type: Improvement
> Components: Kafka Connector
> Affects Versions: 1.4.0
> Reporter: yanxiaobin
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.7.0
>
> Attachments: image-2018-01-30-14-58-58-167.png,
> image-2018-01-31-10-48-59-633.png
>
>
> The method deserialize of KeyedDeserializationSchema needs a parameter
> 'kafka message timestamp' (from ConsumerRecord) .In some business scenarios,
> this is useful！
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
