This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a change to branch 3.3
in repository https://gitbox.apache.org/repos/asf/kafka.git
from ce7d0f5fa51 MINOR: BrokerMetadataSnapshotter must avoid exceeding
batch size (#12486)
new 8db3f0998c6 KAFKA-14124: improve quorum controller fault handling
(#12447)
new 2ee58902d4c MINOR: add :server-common test dependency to :storage
(#12488)
new bbd659325a6 KAFKA-14129: KRaft must check manual assignments for
createTopics are contiguous (#12467)
new 4a94d25b6d2 MINOR: convert some more junit tests to support KRaft
(#12456)
new 480e97914e1 KAFKA-13166 Fix missing ControllerApis error handling
(#12403)
new 112294334f4 MINOR: Convert some junit tests to kraft (#12443)
new 8c8cb111a4f KAFKA-14051: Create metrics reporters in KRaft remote
controllers (#12396)
The 7 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
build.gradle | 4 +
checkstyle/import-control-core.xml | 1 +
checkstyle/import-control.xml | 4 +
checkstyle/suppressions.xml | 2 +
core/src/main/scala/kafka/server/AclApis.scala | 32 +-
.../src/main/scala/kafka/server/BrokerServer.scala | 5 +-
.../main/scala/kafka/server/ControllerApis.scala | 121 ++++---
.../main/scala/kafka/server/ControllerServer.scala | 25 +-
.../scala/kafka/server/DynamicBrokerConfig.scala | 46 ++-
.../main/scala/kafka/server/KafkaRaftServer.scala | 6 +-
.../kafka/server/metadata/KRaftMetadataCache.scala | 2 +-
.../java/kafka/testkit/KafkaClusterTestKit.java | 36 +-
.../kafka/api/BaseProducerSendTest.scala | 102 +++---
.../kafka/api/PlaintextProducerSendTest.scala | 51 +--
.../kafka/api/ProducerCompressionTest.scala | 49 +--
.../api/TransactionsWithMaxInFlightOneTest.scala | 24 +-
.../kafka/server/QuorumTestHarness.scala | 46 ++-
.../kafka/tools/MirrorMakerIntegrationTest.scala | 24 +-
.../scala/unit/kafka/admin/AddPartitionsTest.scala | 164 ++++++---
.../AddPartitionsToTxnRequestServerTest.scala | 16 +-
.../unit/kafka/server/ControllerApisTest.scala | 30 ++
.../unit/kafka/server/EdgeCaseRequestTest.scala | 32 +-
.../kafka/server/KafkaMetricsReporterTest.scala | 55 +--
.../unit/kafka/server/ServerShutdownTest.scala | 10 +-
.../test/scala/unit/kafka/utils/TestUtils.scala | 60 +++-
.../apache/kafka/controller/QuorumController.java | 382 ++++++++++++---------
.../controller/ReplicationControlManager.java | 8 +-
.../metadata/fault/MetadataFaultException.java | 17 +-
.../kafka/metadata/fault/MetadataFaultHandler.java | 20 +-
.../kafka/controller/QuorumControllerTest.java | 25 ++
.../kafka/controller/QuorumControllerTestEnv.java | 15 +
.../apache/kafka/server/fault/FaultHandler.java | 58 ++++
.../server/fault/ProcessExitingFaultHandler.java | 19 +-
.../kafka/server/fault/MockFaultHandler.java | 65 ++++
.../server/fault/MockFaultHandlerException.java | 29 +-
35 files changed, 1069 insertions(+), 516 deletions(-)
copy
clients/src/main/java/org/apache/kafka/common/errors/NotControllerException.java
=>
metadata/src/main/java/org/apache/kafka/metadata/fault/MetadataFaultException.java
(74%)
copy
trogdor/src/main/java/org/apache/kafka/trogdor/task/NoOpTaskController.java =>
metadata/src/main/java/org/apache/kafka/metadata/fault/MetadataFaultHandler.java
(62%)
create mode 100644
server-common/src/main/java/org/apache/kafka/server/fault/FaultHandler.java
copy
trogdor/src/main/java/org/apache/kafka/trogdor/task/NoOpTaskController.java =>
server-common/src/main/java/org/apache/kafka/server/fault/ProcessExitingFaultHandler.java
(65%)
create mode 100644
server-common/src/test/java/org/apache/kafka/server/fault/MockFaultHandler.java
copy
trogdor/src/main/java/org/apache/kafka/trogdor/task/AgentWorkerStatusTracker.java
=>
server-common/src/test/java/org/apache/kafka/server/fault/MockFaultHandlerException.java
(54%)
