This is an automated email from the ASF dual-hosted git repository.
mimaison pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 2f64f6d KAFKA-10321: fix infinite blocking for global stream thread
startup (#9095)
add 819cd45 KAFKA-10120: Deprecate DescribeLogDirsResult.all() and
.values() (#9007)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/admin/DescribeLogDirsResult.java | 84 +++++--
.../kafka/clients/admin/KafkaAdminClient.java | 53 +++--
.../kafka/clients/admin/LogDirDescription.java | 64 +++++
.../apache/kafka/clients/admin/ReplicaInfo.java | 70 ++++++
.../common/requests/DescribeLogDirsResponse.java | 33 ++-
.../kafka/clients/admin/KafkaAdminClientTest.java | 263 ++++++++++++++++++++-
.../main/scala/kafka/admin/LogDirsCommand.scala | 9 +-
.../admin/ReassignPartitionsIntegrationTest.scala | 2 +-
.../kafka/api/AuthorizerIntegrationTest.scala | 2 +-
.../kafka/api/PlaintextAdminIntegrationTest.scala | 2 +-
.../kafka/server/DescribeLogDirsRequestTest.scala | 26 +-
.../PurgeRepartitionTopicIntegrationTest.java | 15 +-
12 files changed, 543 insertions(+), 80 deletions(-)
create mode 100644
clients/src/main/java/org/apache/kafka/clients/admin/LogDirDescription.java
create mode 100644
clients/src/main/java/org/apache/kafka/clients/admin/ReplicaInfo.java
