This is an automated email from the ASF dual-hosted git repository.
rsivaram pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from d87fc21 MINOR: Ensure `InterBrokerSendThread` closes `NetworkClient`
(#9999)
add 4f588f7 KAFKA-10764: Add support for returning topic IDs on create,
supplying topic IDs for delete (#9684)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/kafka/clients/admin/Admin.java | 36 +++++
.../kafka/clients/admin/CreateTopicsResult.java | 24 +++-
...sResult.java => DeleteTopicsWithIdsResult.java} | 13 +-
.../kafka/clients/admin/KafkaAdminClient.java | 104 +++++++++++++-
...Exception.java => UnknownTopicIdException.java} | 6 +-
.../org/apache/kafka/common/protocol/Errors.java | 4 +-
.../kafka/common/requests/DeleteTopicsRequest.java | 46 +++++-
.../common/message/CreateTopicsRequest.json | 4 +-
.../common/message/CreateTopicsResponse.json | 5 +-
.../common/message/DeleteTopicsRequest.json | 11 +-
.../common/message/DeleteTopicsResponse.json | 9 +-
.../kafka/clients/admin/KafkaAdminClientTest.java | 154 ++++++++++++++++++++-
.../kafka/clients/admin/MockAdminClient.java | 43 +++++-
core/src/main/scala/kafka/server/KafkaApis.scala | 38 +++--
.../main/scala/kafka/server/ZkAdminManager.scala | 9 ++
.../kafka/api/AuthorizerIntegrationTest.scala | 125 ++++++++++++++---
.../kafka/api/BaseAdminIntegrationTest.scala | 7 +
.../kafka/api/PlaintextAdminIntegrationTest.scala | 19 +++
.../kafka/api/SaslSslAdminIntegrationTest.scala | 6 +
.../kafka/integration/KafkaServerTestHarness.scala | 15 +-
.../kafka/server/CreateTopicsRequestTest.scala | 6 +
.../kafka/server/DeleteTopicsRequestTest.scala | 57 +++++++-
.../TopicIdWithOldInterBrokerProtocolTest.scala | 60 +++++++-
23 files changed, 745 insertions(+), 56 deletions(-)
copy
clients/src/main/java/org/apache/kafka/clients/admin/{DeleteTopicsResult.java
=> DeleteTopicsWithIdsResult.java} (78%)
copy
clients/src/main/java/org/apache/kafka/common/errors/{InvalidRequiredAcksException.java
=> UnknownTopicIdException.java} (88%)
rename core/src/test/scala/unit/kafka/server/{MetadataRequestIBPTest =>
}/TopicIdWithOldInterBrokerProtocolTest.scala (50%)
