root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity

KAFKA-18867 add tests to describe topic configs with empty name (#19075) 

Reviewers: TengYao Chi <kitingiao@gmail.com>, Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
Nick Guo 2025-03-04 14:56:25 +08:00 committed by GitHub
parent d51817699f
commit 101e15bb1c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala
View File

@ -1624,17 +1624,19 @@ class PlaintextAdminIntegrationTest extends BaseAdminIntegrationTest {
client = createAdminClient client = createAdminClient
val existingTopic = new ConfigResource(ConfigResource.Type.TOPIC, topic) val existingTopic = new ConfigResource(ConfigResource.Type.TOPIC, topic)
client.describeConfigs(Collections.singletonList(existingTopic)).values.get(existingTopic).get() client.describeConfigs(util.List.of(existingTopic)).values.get(existingTopic).get()
val defaultTopic = new ConfigResource(ConfigResource.Type.TOPIC, "")
var describeResult = client.describeConfigs(util.List.of(defaultTopic))
assertFutureThrows(classOf[InvalidTopicException], describeResult.all())
val nonExistentTopic = new ConfigResource(ConfigResource.Type.TOPIC, "unknown") val nonExistentTopic = new ConfigResource(ConfigResource.Type.TOPIC, "unknown")
val describeResult1 = client.describeConfigs(Collections.singletonList(nonExistentTopic)) describeResult = client.describeConfigs(util.List.of(nonExistentTopic))
assertFutureThrows(classOf[UnknownTopicOrPartitionException], describeResult.all())
assertTrue(assertThrows(classOf[ExecutionException], () => describeResult1.values.get(nonExistentTopic).get).getCause.isInstanceOf[UnknownTopicOrPartitionException])
val invalidTopic = new ConfigResource(ConfigResource.Type.TOPIC, "(invalid topic)") val invalidTopic = new ConfigResource(ConfigResource.Type.TOPIC, "(invalid topic)")
val describeResult2 = client.describeConfigs(Collections.singletonList(invalidTopic)) describeResult = client.describeConfigs(util.List.of(invalidTopic))
assertFutureThrows(classOf[InvalidTopicException], describeResult.all())
assertTrue(assertThrows(classOf[ExecutionException], () => describeResult2.values.get(invalidTopic).get).getCause.isInstanceOf[InvalidTopicException])
} }
@Test @Test