Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5485#discussion_r168414749
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseTest.java
---
@@ -696,6 +697,7 @@ public void clear() {
@Override
public void add(T value) throws Exception {
+ Objects.requireNonNull(value, "You cannot add null to a
ListState.");
--- End diff --
Will change---
