This is an automated email from the ASF dual-hosted git repository.
ijuma pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 1dc5063 MINOR: Don't generate unnecessary strings for debug logging
in FetchSessionHandler (#7394)
add 66183f7 KAFKA-8471: Replace control requests/responses with automated
protocol (#7353)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/common/protocol/ApiKeys.java | 19 +-
.../apache/kafka/common/protocol/types/Struct.java | 1 +
.../common/requests/AbstractControlRequest.java | 42 +-
.../kafka/common/requests/AbstractResponse.java | 11 +-
.../requests/AddPartitionsToTxnResponse.java | 2 +-
.../requests/AlterReplicaLogDirsResponse.java | 2 +-
.../kafka/common/requests/BasePartitionState.java | 40 --
.../kafka/common/requests/LeaderAndIsrRequest.java | 430 ++++-------------
.../common/requests/LeaderAndIsrResponse.java | 89 +---
.../common/requests/OffsetCommitResponse.java | 8 +-
.../kafka/common/requests/StopReplicaRequest.java | 190 ++++----
.../kafka/common/requests/StopReplicaResponse.java | 85 +---
.../common/requests/TxnOffsetCommitResponse.java | 2 +-
.../common/requests/UpdateMetadataRequest.java | 527 +++++----------------
.../common/requests/UpdateMetadataResponse.java | 43 +-
...ircularIterator.java => FlattenedIterator.java} | 46 +-
.../{CircularIterator.java => MappedIterator.java} | 37 +-
.../common/message/LeaderAndIsrRequest.json | 16 +-
.../common/message/LeaderAndIsrResponse.json | 2 +-
.../common/message/StopReplicaRequest.json | 4 +-
.../common/message/StopReplicaResponse.json | 2 +-
.../common/message/UpdateMetadataRequest.json | 14 +-
.../apache/kafka/common/message/MessageTest.java | 48 +-
.../kafka/common/requests/ControlRequestTest.java | 87 ----
.../common/requests/LeaderAndIsrRequestTest.java | 147 ++++++
.../common/requests/LeaderAndIsrResponseTest.java | 80 +++-
.../kafka/common/requests/RequestResponseTest.java | 158 ++++--
.../common/requests/StopReplicaRequestTest.java} | 24 +-
.../common/requests/StopReplicaResponseTest.java | 38 +-
.../common/requests/UpdateMetadataRequestTest.java | 187 ++++++++
.../kafka/common/utils/FlattenedIteratorTest.java | 115 +++++
.../kafka/common/utils/MappedIteratorTest.java | 61 +++
.../test/java/org/apache/kafka/test/TestUtils.java | 11 +
core/src/main/scala/kafka/cluster/Partition.scala | 33 +-
.../controller/ControllerChannelManager.scala | 115 +++--
.../scala/kafka/controller/KafkaController.scala | 16 +-
.../src/main/scala/kafka/server/AdminManager.scala | 6 +-
.../kafka/server/DelayedCreatePartitions.scala | 2 +-
.../scala/kafka/server/DelayedElectLeader.scala | 23 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 51 +-
.../main/scala/kafka/server/MetadataCache.scala | 59 +--
.../main/scala/kafka/server/ReplicaManager.scala | 95 ++--
core/src/main/scala/kafka/zk/KafkaZkClient.scala | 2 +-
.../kafka/api/AbstractConsumerTest.scala | 6 +-
.../kafka/api/AdminClientIntegrationTest.scala | 8 +-
.../kafka/api/AuthorizerIntegrationTest.scala | 54 ++-
.../server/DynamicBrokerReconfigurationTest.scala | 2 +-
...PreferredReplicaLeaderElectionCommandTest.scala | 7 +-
.../scala/unit/kafka/cluster/PartitionTest.scala | 255 +++++++---
.../controller/ControllerChannelManagerTest.scala | 75 ++-
.../controller/ControllerIntegrationTest.scala | 26 +-
.../integration/UncleanLeaderElectionTest.scala | 2 +-
.../unit/kafka/network/SocketServerTest.scala | 2 +-
.../kafka/server/BrokerEpochIntegrationTest.scala | 55 ++-
.../scala/unit/kafka/server/FetchRequestTest.scala | 5 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 59 ++-
.../unit/kafka/server/LeaderElectionTest.scala | 26 +-
.../unit/kafka/server/MetadataCacheTest.scala | 239 ++++++++--
.../unit/kafka/server/ReplicaManagerTest.scala | 269 +++++++++--
.../scala/unit/kafka/server/RequestQuotaTest.scala | 35 +-
.../unit/kafka/server/ServerShutdownTest.scala | 2 +-
.../unit/kafka/server/StopReplicaRequestTest.scala | 11 +-
.../server/epoch/LeaderEpochIntegrationTest.scala | 5 +-
.../test/scala/unit/kafka/utils/TestUtils.scala | 18 +-
.../UpdateFollowerFetchStateBenchmark.java | 13 +-
.../integration/utils/IntegrationTestUtils.java | 8 +-
66 files changed, 2297 insertions(+), 1855 deletions(-)
delete mode 100644
clients/src/main/java/org/apache/kafka/common/requests/BasePartitionState.java
copy
clients/src/main/java/org/apache/kafka/common/utils/{CircularIterator.java =>
FlattenedIterator.java} (51%)
copy
clients/src/main/java/org/apache/kafka/common/utils/{CircularIterator.java =>
MappedIterator.java} (58%)
delete mode 100644
clients/src/test/java/org/apache/kafka/common/requests/ControlRequestTest.java
create mode 100644
clients/src/test/java/org/apache/kafka/common/requests/LeaderAndIsrRequestTest.java
copy
clients/src/{main/java/org/apache/kafka/clients/consumer/InvalidOffsetException.java
=> test/java/org/apache/kafka/common/requests/StopReplicaRequestTest.java}
(62%)
create mode 100644
clients/src/test/java/org/apache/kafka/common/requests/UpdateMetadataRequestTest.java
create mode 100644
clients/src/test/java/org/apache/kafka/common/utils/FlattenedIteratorTest.java
create mode 100644
clients/src/test/java/org/apache/kafka/common/utils/MappedIteratorTest.java
