You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2017/10/14 07:08:34 UTC
storm git commit: MINOR: Fix spelling error in comment
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 <sr...@apache.org>
Authored: Sat Oct 14 09:08:20 2017 +0200
Committer: Stig Rohde Døssing <sr...@apache.org>
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."