You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mi...@apache.org on 2020/03/19 15:26:47 UTC
[kafka] branch trunk updated (5c0cf02 -> 4f1e833)
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 5c0cf02 MINOR: return unmodifiableMap for PartitionStates.partitionStateMap. (#7637)
add 4f1e833 KAFKA-9435: DescribeLogDirs automated protocol (#7972)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/admin/KafkaAdminClient.java | 33 +++--
.../org/apache/kafka/common/protocol/ApiKeys.java | 12 +-
.../kafka/common/requests/AbstractResponse.java | 2 +-
.../common/requests/DescribeLogDirsRequest.java | 111 +++------------
.../common/requests/DescribeLogDirsResponse.java | 158 +++++----------------
.../common/message/DescribeLogDirsRequest.json | 7 +-
.../common/message/DescribeLogDirsResponse.json | 5 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 13 +-
.../main/scala/kafka/server/ReplicaManager.scala | 40 ++++--
.../kafka/api/AuthorizerIntegrationTest.scala | 5 +-
.../kafka/server/DescribeLogDirsRequestTest.scala | 3 +-
.../scala/unit/kafka/server/RequestQuotaTest.scala | 6 +-
12 files changed, 132 insertions(+), 263 deletions(-)