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 <karthikkalaghatgi...@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 <karthikkalaghatgi...@gmail.com>
Reviewers: huxi <huxi...@hotmail.com>, Manikumar Reddy
<manikumar.re...@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])
