kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From maniku...@apache.org
Subject [kafka] branch trunk updated: KAFKA-7950; Update description for the "time" parameter for GetOffsetShell
Date Thu, 07 Mar 2019 16:25:33 GMT
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 <karthikkalaghatgi123@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 <karthikkalaghatgi123@gmail.com>
    
    Reviewers: huxi <huxi_2b@hotmail.com>, Manikumar Reddy <manikumar.reddy@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])


Mime
View raw message