[GitHub] [flink] curcur commented on issue #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

2020-04-21 Thread GitBox
curcur commented on issue #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-617021982 List some of the points here, just in case I forgot :-). We can chat details offline. 1. If I am understanding correctly (please ignore if I am not), the original idea is to

[GitHub] [flink] curcur commented on issue #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

2020-04-20 Thread GitBox
curcur commented on issue #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-616402618 Hey @AHeise , Thank you so much for taking the time to review the code and providing feedback! I think you are totally right: I have the same confusion when I first read the

[GitHub] [flink] curcur commented on issue #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

2020-04-15 Thread GitBox
curcur commented on issue #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle URL: https://github.com/apache/flink/pull/11725#issuecomment-613859547 add Java Docs This is an automated message from the