Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5485#discussion_r168772337
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseTest.java
---
@@ -696,6 +696,7 @@ public void clear() {
@Override
--- End diff --
fixing---
