Github user srdo commented on a diff in the pull request:
https://github.com/apache/storm/pull/2465#discussion_r158114673
--- Diff:
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/MaxUncommittedOffsetTest.java
---
@@ -71,6 +76,9 @@
1,
KafkaSpoutRetryExponentialBackoff.TimeInterval.seconds(initialRetryDelaySecs)))
//Retry once after a minute
.build();
private KafkaSpout<String, String> spout;
+ private KafkaConsumer<String, String> consumer;
--- End diff --
This doesn't seem to be used?
---
