You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by mi...@apache.org on 2015/04/22 16:54:19 UTC
storm git commit: System.time.currentTimeMillis() should actually be
System.currentTimeMillis()
Repository: storm
Updated Branches:
refs/heads/master 50db5a5e8 -> eb4d0f117
System.time.currentTimeMillis() should actually be System.currentTimeMillis()
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/eb4d0f11
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/eb4d0f11
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/eb4d0f11
Branch: refs/heads/master
Commit: eb4d0f1174d4e9f60862c2fc8701972e11f2bab7
Parents: 50db5a5
Author: Michael G. Noll <mn...@verisign.com>
Authored: Wed Apr 22 16:53:52 2015 +0200
Committer: Michael G. Noll <mn...@verisign.com>
Committed: Wed Apr 22 16:53:52 2015 +0200
----------------------------------------------------------------------
external/storm-kafka/README.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/eb4d0f11/external/storm-kafka/README.md
----------------------------------------------------------------------
diff --git a/external/storm-kafka/README.md b/external/storm-kafka/README.md
index 4ab7b4f..da8a49a 100644
--- a/external/storm-kafka/README.md
+++ b/external/storm-kafka/README.md
@@ -133,7 +133,7 @@ setting `KafkaConfig.startOffsetTime` as follows:
1. `kafka.api.OffsetRequest.EarliestTime()`: read from the beginning of the topic (i.e. from the oldest messages onwards)
2. `kafka.api.OffsetRequest.LatestTime()`: read from the end of the topic (i.e. any new messsages that are being written to the topic)
-3. A Unix timestamp aka seconds since the epoch (e.g. via `System.time.currentTimeMillis()`):
+3. A Unix timestamp aka seconds since the epoch (e.g. via `System.currentTimeMillis()`):
see [How do I accurately get offsets of messages for a certain timestamp using OffsetRequest?](https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-HowdoIaccuratelygetoffsetsofmessagesforacertaintimestampusingOffsetRequest?) in the Kafka FAQ
As the topology runs the Kafka spout keeps track of the offsets it has read and emitted by storing state information