GitHub user FredTing opened a pull request:
https://github.com/apache/flink/pull/6105
[FLINK-8500] Get the timestamp of the Kafka message from kafka consumer
## What is the purpose of the change
This pull request make the Kafka timestamp and timestampType available in
the
Github user FredTing commented on the issue:
https://github.com/apache/flink/pull/5958
Closing this PR because new insights
---
Github user FredTing closed the pull request at:
https://github.com/apache/flink/pull/5958
---
Github user FredTing commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186480680
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/serialization/ConsumerRecordMetaInfo.java
---
@@ -0,0 +1,73 @@
+/*
+ * Licensed to
Github user FredTing commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186479633
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/serialization/DeserializationSchema.java
---
@@ -42,14 +42,22 @@
@Public
public
Github user FredTing commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186479026
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/serialization/DeserializationSchema.java
---
@@ -42,14 +42,22 @@
@Public
public
Github user FredTing commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186465223
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/serialization/ConsumerRecordMetaInfo.java
---
@@ -0,0 +1,73 @@
+/*
+ * Licensed to
Github user FredTing commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186462871
--- Diff:
flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka010Fetcher.java
---
@@ -78,6
GitHub user FredTing opened a pull request:
https://github.com/apache/flink/pull/5958
[FLINK-8500] Get the timestamp of the Kafka message from kafka consumer
## What is the purpose of the change
This pull request make the Kafka timestamp and timestampType available in
the
Github user FredTing closed the pull request at:
https://github.com/apache/flink/pull/5939
---
Github user FredTing commented on the issue:
https://github.com/apache/flink/pull/5939
I'm closing this Pull Request and will make a new one with the newer
approach as discussed in the jira issue
---
GitHub user FredTing opened a pull request:
https://github.com/apache/flink/pull/5939
[FLINK-8500] [Kafka Connector] Get the timestamp of the Kafka message from
kafka consumer
## What is the purpose of the change
This pull request make the Kafka timestamp and timestampType
12 matches
Mail list logo
