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: [email protected] With regards, Apache Git Services
