You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ma...@apache.org on 2019/03/07 16:25:33 UTC
[kafka] branch trunk updated: KAFKA-7950;
Update description for the "time" parameter for GetOffsetShell
This is an automated email from the ASF dual-hosted git repository.
manikumar pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new f708e78 KAFKA-7950; Update description for the "time" parameter for GetOffsetShell
f708e78 is described below
commit f708e782947c340b480882d61f28a98623226583
Author: KartikVK <ka...@gmail.com>
AuthorDate: Thu Mar 7 21:55:14 2019 +0530
KAFKA-7950; Update description for the "time" parameter for GetOffsetShell
Added additional description for the "time" parameter for GetOffsetShell which adds " No offset is returned if timestamp provided is greater than recently committed record timestamp." in the description.
Author: KartikVK <ka...@gmail.com>
Reviewers: huxi <hu...@hotmail.com>, Manikumar Reddy <ma...@gmail.com>
Closes #6357 from Kartikvk1996/kartik-branch
---
core/src/main/scala/kafka/tools/GetOffsetShell.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/src/main/scala/kafka/tools/GetOffsetShell.scala b/core/src/main/scala/kafka/tools/GetOffsetShell.scala
index eafddc6..3474974 100644
--- a/core/src/main/scala/kafka/tools/GetOffsetShell.scala
+++ b/core/src/main/scala/kafka/tools/GetOffsetShell.scala
@@ -46,7 +46,7 @@ object GetOffsetShell {
.describedAs("partition ids")
.ofType(classOf[String])
.defaultsTo("")
- val timeOpt = parser.accepts("time", "timestamp of the offsets before that")
+ val timeOpt = parser.accepts("time", "timestamp of the offsets before that. [Note: No offset is returned, if the timestamp greater than recently commited record timestamp is given.]")
.withRequiredArg
.describedAs("timestamp/-1(latest)/-2(earliest)")
.ofType(classOf[java.lang.Long])