[ https://issues.apache.org/jira/browse/KAFKA-15729 ]
Owen C.H. Leung deleted comment on KAFKA-15729:
-----------------------------------------
was (Author: JIRAUSER300460):
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)
