dengziming commented on a change in pull request #11936:
URL: https://github.com/apache/kafka/pull/11936#discussion_r834344420
##########
File path: core/src/test/scala/kafka/tools/GetOffsetShellTest.scala
##########
@@ -166,6 +166,13 @@ class GetOffsetShellTest extends KafkaServerTestHarness
with Logging {
)
}
+ @Test
+ def testNoOffsetIfTimestampGreaterThanLatestRecord(): Unit = {
Review comment:
In fact, We will first list and filter topic partitions before getting
their offsets, so it's hard to test error cases here, for example, if the error
code is `TOPIC_AUTHORIZATION_FAILED`, then the topic will not be listed in the
first step.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
