Github user hmcl commented on a diff in the pull request:
https://github.com/apache/storm/pull/2367#discussion_r144079454
--- Diff:
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/OffsetManager.java
---
@@ -163,8 +167,9 @@ public long commit(OffsetAndMetadata committedOffset) {
LOG.trace("{}", this);
- LOG.debug("Committed [{}] offsets in the range [{}-{}] for
topic-partition [{}].",
- numCommittedOffsets, preCommitCommittedOffsets + 1,
this.committedOffset, tp);
+ LOG.debug("Committed [{}] offsets in the range [{}-{}] for
topic-partition [{}]."
+ + " Processing will resume at [{}] if the spout restarts.",
--- End diff --
at offset [{}] in case of a spout restart.
---
