[ https://issues.apache.org/jira/browse/KAFKA-15729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17820337#comment-17820337 ]
Owen C.H. Leung commented on KAFKA-15729: ----------------------------------------- I tried to work on this issue by extending this test to KRaft. However, I got the following exception when executing locally (FYI ZK mode works just fine): {code:java} org.apache.kafka.common.KafkaException: Failed to create new KafkaAdminClient at org.apache.kafka.clients.admin.KafkaAdminClient.createInternal(KafkaAdminClient.java:542) at org.apache.kafka.clients.admin.KafkaAdminClient.createInternal(KafkaAdminClient.java:493) at org.apache.kafka.clients.admin.Admin.create(Admin.java:137) Caused by: org.apache.kafka.common.config.ConfigException: You must set either bootstrap.servers or bootstrap.controllers at org.apache.kafka.clients.admin.internals.AdminBootstrapAddresses.fromConfig(AdminBootstrapAddresses.java:62){code} >From the stdout, I can see that `bootstrap.servers` is an empty list: {code:java} [2024-02-24 20:33:37,572] INFO AdminClientConfig values: auto.include.jmx.reporter = true bootstrap.controllers = [] bootstrap.servers = [] {code} Shouldn't the address of bootstrap server be sent over by controller automatically even in Kraft mode ? > KRaft support in GetOffsetShellTest > ----------------------------------- > > Key: KAFKA-15729 > URL: https://issues.apache.org/jira/browse/KAFKA-15729 > Project: Kafka > Issue Type: Task > Components: core > Reporter: Sameer Tejani > Priority: Minor > Labels: kraft, kraft-test, newbie > > The following tests in GetOffsetShellTest in > tools/src/test/java/org/apache/kafka/tools/GetOffsetShellTest.java need to be > updated to support KRaft > 62 : def testNoFilterOptions(): Unit = { > 68 : def testInternalExcluded(): Unit = { > 74 : def testTopicNameArg(): Unit = { > 82 : def testTopicPatternArg(): Unit = { > 88 : def testPartitionsArg(): Unit = { > 94 : def testTopicPatternArgWithPartitionsArg(): Unit = { > 100 : def testTopicPartitionsArg(): Unit = { > 116 : def testGetLatestOffsets(time: String): Unit = { > 131 : def testGetEarliestOffsets(time: String): Unit = { > 146 : def testGetOffsetsByMaxTimestamp(time: String): Unit = { > 155 : def testGetOffsetsByTimestamp(): Unit = { > 170 : def testNoOffsetIfTimestampGreaterThanLatestRecord(): Unit = { > 177 : def testTopicPartitionsArgWithInternalExcluded(): Unit = { > 192 : def testTopicPartitionsArgWithInternalIncluded(): Unit = { > 198 : def testTopicPartitionsNotFoundForNonExistentTopic(): Unit = { > 203 : def testTopicPartitionsNotFoundForExcludedInternalTopic(): Unit = { > 208 : def testTopicPartitionsNotFoundForNonMatchingTopicPartitionPattern(): > Unit = { > 213 : def testTopicPartitionsFlagWithTopicFlagCauseExit(): Unit = { > 218 : def testTopicPartitionsFlagWithPartitionsFlagCauseExit(): Unit = { > Scanned 279 lines. Found 0 KRaft tests out of 19 tests -- This message was sent by Atlassian Jira (v8.20.10#820010)