Github user stevenzwu commented on the issue:
https://github.com/apache/flink/pull/4607
@aljoscha is there any doc/write-up about the reworking of BucketingSink?
---
Github user stevenzwu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4357#discussion_r128642917
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
Github user stevenzwu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4357#discussion_r128642186
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
Github user stevenzwu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4357#discussion_r128113797
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
