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

2018-10-01 Thread GitBox
pnowojski commented on issue #6703: [FLINK-9697] Provide connector for Kafka 2.0.0 URL: https://github.com/apache/flink/pull/6703#issuecomment-425903372 @yanghua I would assume that deadlocking/becoming unresponsive just proves that our `at-least-once` test is broken and should be replaced

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

2018-09-17 Thread GitBox
pnowojski commented on issue #6703: [FLINK-9697] Provide connector for Kafka 2.0.0 URL: https://github.com/apache/flink/pull/6703#issuecomment-422001108 In existing `Kafka011ProducerExactlyOnceITCase`, at least once tests are not passing. Please check the comment in `Kafka011ProducerExact

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

2018-09-17 Thread GitBox
pnowojski commented on issue #6703: [FLINK-9697] Provide connector for Kafka 2.0.0 URL: https://github.com/apache/flink/pull/6703#issuecomment-421932719 @yanghua CC me and/or request review when this will be ready to review T