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 4c2bd56 MINOR: Bump version to 2.5.0-SNAPSHOT (#7455)
add c06e45a KAFKA-8985; Add flexible version support to inter-broker APIs
(#7453)
No new revisions were added by this update.
Summary of changes:
.../common/requests/ControlledShutdownRequest.java | 8 ++--
.../kafka/common/requests/LeaderAndIsrRequest.java | 13 +-----
.../kafka/common/requests/StopReplicaRequest.java | 11 +----
.../common/requests/UpdateMetadataRequest.java | 9 ++--
.../common/message/ControlledShutdownRequest.json | 4 +-
.../common/message/ControlledShutdownResponse.json | 4 +-
.../common/message/LeaderAndIsrRequest.json | 4 +-
.../common/message/LeaderAndIsrResponse.json | 4 +-
.../common/message/StopReplicaRequest.json | 4 +-
.../common/message/StopReplicaResponse.json | 4 +-
.../common/message/UpdateMetadataRequest.json | 4 +-
.../common/message/UpdateMetadataResponse.json | 4 +-
.../requests/ControlledShutdownRequestTest.java | 51 ++++++++++++++++++++++
.../common/requests/LeaderAndIsrRequestTest.java | 24 ++++++++++
.../common/requests/StopReplicaRequestTest.java | 27 ++++++++++++
.../common/requests/UpdateMetadataRequestTest.java | 24 ++++++++++
core/src/main/scala/kafka/api/ApiVersion.scala | 11 ++++-
.../controller/ControllerChannelManager.scala | 9 ++--
core/src/main/scala/kafka/server/KafkaServer.scala | 5 ++-
.../test/scala/unit/kafka/api/ApiVersionTest.scala | 3 +-
.../controller/ControllerChannelManagerTest.scala | 12 +++--
21 files changed, 180 insertions(+), 59 deletions(-)
create mode 100644
clients/src/test/java/org/apache/kafka/common/requests/ControlledShutdownRequestTest.java
