Github user hmcl commented on a diff in the pull request: https://github.com/apache/storm/pull/2454#discussion_r156208684 --- Diff: external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java --- @@ -223,29 +220,24 @@ private long doSeek(TopicPartition tp, OffsetAndMetadata committedOffset) { @Override public void nextTuple() { try { - if (initialized) { --- End diff -- Why is this flag no longer necessary?
---