[GitHub] aljoscha commented on issue #6703: [FLINK-9697] Provide connector for modern Kafka

2018-10-15 Thread GitBox
aljoscha commented on issue #6703: [FLINK-9697] Provide connector for modern Kafka URL: https://github.com/apache/flink/pull/6703#issuecomment-429881898 ``` 14:37:26.192 [ERROR] /home/travis/build/apache/flink/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/st

[GitHub] aljoscha commented on issue #6703: [FLINK-9697] Provide connector for modern Kafka

2018-10-16 Thread GitBox
aljoscha commented on issue #6703: [FLINK-9697] Provide connector for modern Kafka URL: https://github.com/apache/flink/pull/6703#issuecomment-430139529 @yanghua You don't have to do anything more, I'll merge shortly. This is

[GitHub] aljoscha commented on issue #6703: [FLINK-9697] Provide connector for modern Kafka

2018-10-16 Thread GitBox
aljoscha commented on issue #6703: [FLINK-9697] Provide connector for modern Kafka URL: https://github.com/apache/flink/pull/6703#issuecomment-430181885 @alexeyt820 are you working on header and timestamp access to get it rebased and working on top of this? ---

[GitHub] aljoscha commented on issue #6703: [FLINK-9697] Provide connector for modern Kafka

2018-10-16 Thread GitBox
aljoscha commented on issue #6703: [FLINK-9697] Provide connector for modern Kafka URL: https://github.com/apache/flink/pull/6703#issuecomment-430292958 Thanks a lot for iterating on this and coming up with a good solution in the end, @yanghua! And also thanks a lot to @eliaslevy fo

[GitHub] aljoscha commented on issue #6703: [FLINK-9697] Provide connector for modern Kafka

2018-10-16 Thread GitBox
aljoscha commented on issue #6703: [FLINK-9697] Provide connector for modern Kafka URL: https://github.com/apache/flink/pull/6703#issuecomment-430293083 I merged manually to master. This is an automated message from the Apach