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) {