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

KAFKA-19659: Wrong generic type for UnregisterBrokerOptions (#20490) 

Fix wrong generic type for UnregisterBrokerOptions

Reviewers: Andrew Schofield <aschofield@confluent.io>
This commit is contained in:
Kuan-Po Tseng 2025-09-05 23:50:05 +08:00 committed by GitHub
parent 29ce96151c
commit af03353f71
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
clients/src/main/java/org/apache/kafka/clients/admin/UnregisterBrokerOptions.java
View File

@ -20,5 +20,5 @@ package org.apache.kafka.clients.admin;
/** /**
* Options for {@link Admin#unregisterBroker(int, UnregisterBrokerOptions)}. * Options for {@link Admin#unregisterBroker(int, UnregisterBrokerOptions)}.
*/ */
public class UnregisterBrokerOptions extends AbstractOptions<UpdateFeaturesOptions> { public class UnregisterBrokerOptions extends AbstractOptions<UnregisterBrokerOptions> {
} }

4
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
View File

@ -9952,9 +9952,7 @@ public class KafkaAdminClientTest {
env.kafkaClient().setNodeApiVersions( env.kafkaClient().setNodeApiVersions(
NodeApiVersions.create(ApiKeys.UNREGISTER_BROKER.id, (short) 0, (short) 0)); NodeApiVersions.create(ApiKeys.UNREGISTER_BROKER.id, (short) 0, (short) 0));
UnregisterBrokerOptions options = new UnregisterBrokerOptions(); UnregisterBrokerResult result = env.adminClient().unregisterBroker(nodeId, new UnregisterBrokerOptions().timeoutMs(10));
options.timeoutMs = 10;
UnregisterBrokerResult result = env.adminClient().unregisterBroker(nodeId, options);
// Validate response // Validate response
assertNotNull(result.all()); assertNotNull(result.all());