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