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 bca2a4e MINOR: clarify variables for skipping idempotent source
updates (#9316)
add 57de67d KAFKA-8836; Add `AlterISR` RPC and use it for ISR
modifications (#9100)
No new revisions were added by this update.
Summary of changes:
...ion.java => InvalidUpdateVersionException.java} | 8 +-
.../org/apache/kafka/common/protocol/ApiKeys.java | 5 +-
.../org/apache/kafka/common/protocol/Errors.java | 4 +-
.../kafka/common/requests/AbstractRequest.java | 3 +
.../kafka/common/requests/AbstractResponse.java | 3 +
...fsetDeleteRequest.java => AlterIsrRequest.java} | 80 +++--
...MetadataResponse.java => AlterIsrResponse.java} | 36 +--
.../resources/common/message/AlterIsrRequest.json | 42 +++
...ignmentsResponse.json => AlterIsrResponse.json} | 34 ++-
core/src/main/scala/kafka/api/ApiVersion.scala | 9 +
core/src/main/scala/kafka/api/LeaderAndIsr.scala | 10 +
core/src/main/scala/kafka/cluster/Partition.scala | 339 +++++++++++++++------
.../scala/kafka/controller/KafkaController.scala | 155 +++++++++-
.../main/scala/kafka/server/AlterIsrManager.scala | 180 +++++++++++
... => BrokerToControllerChannelManagerImpl.scala} | 30 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 22 +-
core/src/main/scala/kafka/server/KafkaServer.scala | 15 +-
.../main/scala/kafka/server/ReplicaManager.scala | 13 +-
.../unit/kafka/cluster/AbstractPartitionTest.scala | 6 +-
.../unit/kafka/cluster/PartitionLockTest.scala | 6 +-
.../scala/unit/kafka/cluster/PartitionTest.scala | 244 +++++++++++----
.../controller/ControllerIntegrationTest.scala | 52 +++-
.../AbstractCoordinatorConcurrencyTest.scala | 2 +-
.../unit/kafka/server/AlterIsrManagerTest.scala | 302 ++++++++++++++++++
.../server/HighwatermarkPersistenceTest.scala | 6 +-
.../unit/kafka/server/IsrExpirationTest.scala | 6 +-
.../kafka/server/ReplicaManagerQuotasTest.scala | 4 +-
.../unit/kafka/server/ReplicaManagerTest.scala | 21 +-
.../scala/unit/kafka/server/RequestQuotaTest.scala | 3 +
.../server/epoch/OffsetsForLeaderEpochTest.scala | 7 +-
.../test/scala/unit/kafka/utils/TestUtils.scala | 19 ++
.../jmh/fetcher/ReplicaFetcherThreadBenchmark.java | 5 +-
.../partition/PartitionMakeFollowerBenchmark.java | 5 +-
.../UpdateFollowerFetchStateBenchmark.java | 5 +-
.../apache/kafka/jmh/server/CheckpointBench.java | 5 +
35 files changed, 1403 insertions(+), 283 deletions(-)
copy
clients/src/main/java/org/apache/kafka/common/errors/{AuthorizationException.java
=> InvalidUpdateVersionException.java} (78%)
copy
clients/src/main/java/org/apache/kafka/common/requests/{OffsetDeleteRequest.java
=> AlterIsrRequest.java} (53%)
copy
clients/src/main/java/org/apache/kafka/common/requests/{UpdateMetadataResponse.java
=> AlterIsrResponse.java} (60%)
create mode 100644
clients/src/main/resources/common/message/AlterIsrRequest.json
copy
clients/src/main/resources/common/message/{AlterPartitionReassignmentsResponse.json
=> AlterIsrResponse.json} (55%)
create mode 100644 core/src/main/scala/kafka/server/AlterIsrManager.scala
rename
core/src/main/scala/kafka/server/{BrokerToControllerChannelManager.scala =>
BrokerToControllerChannelManagerImpl.scala} (88%)
create mode 100644
core/src/test/scala/unit/kafka/server/AlterIsrManagerTest.scala
