alexeyt820 commented on issue #6615: [FLINK-8354] [flink-connectors] Add
ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#issuecomment-465594547
@aljoscha, sure. Let me know if I can help
alexeyt820 commented on issue #6615: [FLINK-8354] [flink-connectors] Add
ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#issuecomment-457051271
The compile problem was due master flink-connector-kafka-base uses Kafka
0.10.2.1, where
alexeyt820 commented on issue #6615: [FLINK-8354] [flink-connectors] Add
ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#issuecomment-456910348
Weird build is fine locally using 1.8.0_181-b13, but fails on Travis with
1.8.0_151-b12:
alexeyt820 commented on issue #6615: [FLINK-8354] [flink-connectors] Add
ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#issuecomment-432846236
@yanghua, @aljoscha is anything else need to be done with this PR ?
alexeyt820 commented on issue #6615: [FLINK-8354] [flink-connectors] Add
ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#issuecomment-431860212
Rebased on top of #6703 and implemented KeyedDeserializationSchema.Record
for Kafka 2.0 (had to keep
alexeyt820 commented on issue #6615: [FLINK-8354] [flink-connectors] Add
ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#issuecomment-421014612
@tzulitai, using ```Record``` wrapping Kafka ```ConsumerRecord``` allows to
add for example timestamp
alexeyt820 commented on issue #6615: [FLINK-8354] [flink-connectors] Add
ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#issuecomment-420812548
@yanghua, @aljoscha any other suggestions?
