Repository: storm Updated Branches: refs/heads/master 94dab8d9f -> ca022899b
MINOR: Fix spelling error in comment Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/ca022899 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/ca022899 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/ca022899 Branch: refs/heads/master Commit: ca022899b3c433318f4e427e873d1ae583bee13b Parents: 94dab8d Author: Stig Rohde Døssing <[email protected]> Authored: Sat Oct 14 09:08:20 2017 +0200 Committer: Stig Rohde Døssing <[email protected]> Committed: Sat Oct 14 09:08:20 2017 +0200 ---------------------------------------------------------------------- .../java/org/apache/storm/kafka/spout/internal/OffsetManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/ca022899/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/OffsetManager.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/OffsetManager.java b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/OffsetManager.java index 56f6701..075c4dd 100755 --- a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/OffsetManager.java +++ b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/OffsetManager.java @@ -97,7 +97,7 @@ public class OffsetManager { So, if the topic doesn't contain offset = nextCommitOffset (possible if the topic is compacted or deleted), the consumer should jump to the next logical point in the topic. Next logical offset should be the - first element after nextCommitOffsset in the ascending ordered emitted set. + first element after nextCommitOffset in the ascending ordered emitted set. */ LOG.debug("Processed non-sequential offset." + " The earliest uncommitted offset is no longer part of the topic."
