You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2020/04/14 18:40:30 UTC
[kafka] branch trunk updated (ea47a88 -> 7c7d55d)
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 ea47a88 MINOR: remove stream simple benchmark suite (#8353)
add 7c7d55d KAFKA-9539; Add leader epoch in StopReplicaRequest (KIP-570) (#8257)
No new revisions were added by this update.
Summary of changes:
.../kafka/common/requests/StopReplicaRequest.java | 138 ++++++++----
.../kafka/common/requests/StopReplicaResponse.java | 7 +-
.../common/message/StopReplicaRequest.json | 28 ++-
.../common/message/StopReplicaResponse.json | 6 +-
.../kafka/common/requests/RequestResponseTest.java | 38 +++-
.../common/requests/StopReplicaRequestTest.java | 197 ++++++++++++++++-
.../common/requests/StopReplicaResponseTest.java | 26 ++-
core/src/main/scala/kafka/api/ApiVersion.scala | 11 +-
core/src/main/scala/kafka/api/LeaderAndIsr.scala | 2 +
.../controller/ControllerChannelManager.scala | 108 +++++++---
core/src/main/scala/kafka/log/LogManager.scala | 2 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 34 ++-
.../main/scala/kafka/server/ReplicaManager.scala | 103 +++++++--
.../kafka/api/AuthorizerIntegrationTest.scala | 11 +-
.../controller/ControllerChannelManagerTest.scala | 238 +++++++++++++++------
.../kafka/server/BrokerEpochIntegrationTest.scala | 11 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 85 +++++++-
.../unit/kafka/server/ReplicaManagerTest.scala | 207 +++++++++++++++++-
.../scala/unit/kafka/server/RequestQuotaTest.scala | 13 +-
.../unit/kafka/server/StopReplicaRequestTest.scala | 24 ++-
20 files changed, 1065 insertions(+), 224 deletions(-)