This is an automated email from the ASF dual-hosted git repository.

tigerlee pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 1fd7833  variable "timestamp" should be -1 when the timestamp 
parameter is set to "now"
     new a62b70b  Merge pull request #1077 from 
ssssssnake/issue-resetOffsetByTime
1fd7833 is described below

commit 1fd78338be7bd3bb527e1671324deb9fb78ef73b
Author: ssssssnake <[email protected]>
AuthorDate: Tue Mar 12 14:22:36 2019 +0800

    variable "timestamp" should be -1 when the timestamp parameter is set to 
"now"
---
 .../apache/rocketmq/tools/command/offset/ResetOffsetByTimeCommand.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeCommand.java
 
b/tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeCommand.java
index 3f2bc1b..266de75 100644
--- 
a/tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeCommand.java
+++ 
b/tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeCommand.java
@@ -75,7 +75,7 @@ public class ResetOffsetByTimeCommand implements SubCommand {
             String group = commandLine.getOptionValue("g").trim();
             String topic = commandLine.getOptionValue("t").trim();
             String timeStampStr = commandLine.getOptionValue("s").trim();
-            long timestamp = timeStampStr.equals("now") ? 
System.currentTimeMillis() : 0;
+            long timestamp = timeStampStr.equals("now") ? -1 : 0;
 
             try {
                 if (timestamp == 0) {

Reply via email to