Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5485#discussion_r168767915
--- 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 --
And also, there is the `update()` method in the `ListState` interface
that should be changed in all implementations.---
