This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 5b3351e KAFKA-10761; Kafka Raft update log start offset (#9816)
add e9edf10 KAFKA-12238; Implement `DescribeProducers` API from KIP-664
(#9979)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/common/protocol/ApiKeys.java | 3 +-
.../kafka/common/requests/AbstractRequest.java | 2 +
.../kafka/common/requests/AbstractResponse.java | 2 +
.../common/requests/DescribeProducersRequest.java | 97 +++++++++++++++++
...esponse.java => DescribeProducersResponse.java} | 52 ++++-----
...sRequest.json => DescribeProducersRequest.json} | 14 ++-
...esponse.json => DescribeProducersResponse.json} | 30 ++---
.../kafka/common/requests/RequestResponseTest.java | 48 +++++++-
core/src/main/scala/kafka/cluster/Partition.scala | 19 +++-
core/src/main/scala/kafka/log/Log.scala | 17 ++-
.../scala/kafka/network/RequestConvertToJson.scala | 2 +
core/src/main/scala/kafka/server/KafkaApis.scala | 41 ++++++-
.../main/scala/kafka/server/ReplicaManager.scala | 18 ++-
.../kafka/api/AuthorizerIntegrationTest.scala | 29 ++++-
core/src/test/scala/unit/kafka/log/LogTest.scala | 86 ++++++++++++++-
.../scala/unit/kafka/server/KafkaApisTest.scala | 121 ++++++++++++++++++---
.../unit/kafka/server/ReplicaManagerTest.scala | 99 ++++++++++++++++-
.../scala/unit/kafka/server/RequestQuotaTest.scala | 6 +
18 files changed, 599 insertions(+), 87 deletions(-)
create mode 100644
clients/src/main/java/org/apache/kafka/common/requests/DescribeProducersRequest.java
copy
clients/src/main/java/org/apache/kafka/common/requests/{AlterReplicaLogDirsResponse.java
=> DescribeProducersResponse.java} (59%)
copy
clients/src/main/resources/common/message/{DescribeUserScramCredentialsRequest.json
=> DescribeProducersRequest.json} (67%)
copy
clients/src/main/resources/common/message/{AlterPartitionReassignmentsResponse.json
=> DescribeProducersResponse.json} (56%)
