kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject [kafka] branch trunk updated (1dc5063 -> 66183f7)
Date Sun, 29 Sep 2019 02:40:07 GMT
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


Mime
View raw message