This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from ea7b145860e KAFKA-19390: Call safeForceUnmap() in
AbstractIndex.resize() on Linux to prevent stale mmap of index files (#19961)
add d86ba7f54af KAFKA-18681: Created GetReplicaLogInfo RPCs (#19664)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/common/protocol/ApiKeys.java | 4 +-
.../kafka/common/requests/AbstractRequest.java | 2 +
.../kafka/common/requests/AbstractResponse.java | 2 +
.../common/requests/GetReplicaLogInfoRequest.java | 98 ++++++
...esponse.java => GetReplicaLogInfoResponse.java} | 58 +--
...sRequest.json => GetReplicaLogInfoRequest.json} | 18 +-
.../common/message/GetReplicaLogInfoResponse.json | 43 +++
.../kafka/common/requests/RequestResponseTest.java | 18 +
.../kafka/server/builders/KafkaApisBuilder.java | 10 +-
.../src/main/scala/kafka/server/BrokerServer.scala | 3 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 78 ++++-
.../scala/unit/kafka/server/KafkaApisTest.scala | 390 ++++++++++++++++++++-
.../scala/unit/kafka/server/RequestQuotaTest.scala | 3 +
.../apache/kafka/network/RequestConvertToJson.java | 8 +
14 files changed, 692 insertions(+), 43 deletions(-)
create mode 100644
clients/src/main/java/org/apache/kafka/common/requests/GetReplicaLogInfoRequest.java
copy
clients/src/main/java/org/apache/kafka/common/requests/{DescribeProducersResponse.java
=> GetReplicaLogInfoResponse.java} (57%)
copy clients/src/main/resources/common/message/{DescribeProducersRequest.json
=> GetReplicaLogInfoRequest.json} (64%)
create mode 100644
clients/src/main/resources/common/message/GetReplicaLogInfoResponse.json
