kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch 2.1 updated (ab6269e -> c226bda)
Date Fri, 05 Oct 2018 20:42:38 GMT
This is an automated email from the ASF dual-hosted git repository.

jgus pushed a change to branch 2.1
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from ab6269e  KAFKA-6914; Set parent classloader of DelegatingClassLoader same as the
worker's (#5720)
     new bcef30d  KAFKA-7395; Add fencing to replication protocol (KIP-320) (#5661)
     new c226bda  HOTFIX: Compilation error in GroupMetadataManagerTest (#5752)

The 2 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:
 .../kafka/clients/consumer/internals/Fetcher.java  |   9 +-
 ...eption.java => FencedLeaderEpochException.java} |  17 +-
 ...ption.java => UnknownLeaderEpochException.java} |  12 +-
 .../org/apache/kafka/common/protocol/Errors.java   |  13 +-
 .../kafka/common/requests/FetchResponse.java       |  15 +-
 .../kafka/common/requests/ListOffsetResponse.java  |  16 +-
 .../requests/OffsetsForLeaderEpochRequest.java     |  11 +-
 .../requests/OffsetsForLeaderEpochResponse.java    |  13 +
 .../main/scala/kafka/cluster/BrokerEndPoint.scala  |   4 +
 core/src/main/scala/kafka/cluster/Partition.scala  | 360 +++++++++++++++----
 core/src/main/scala/kafka/cluster/Replica.scala    |  10 +-
 .../coordinator/group/GroupMetadataManager.scala   |   8 +-
 .../transaction/TransactionStateManager.scala      |   2 +-
 core/src/main/scala/kafka/log/Log.scala            | 102 ++++--
 .../kafka/server/AbstractFetcherManager.scala      |  55 +--
 .../scala/kafka/server/AbstractFetcherThread.scala | 255 ++++++++-----
 .../scala/kafka/server/DelayedDeleteRecords.scala  |   2 +-
 .../src/main/scala/kafka/server/DelayedFetch.scala |  56 +--
 .../main/scala/kafka/server/FetchDataInfo.scala    |   5 +
 core/src/main/scala/kafka/server/KafkaApis.scala   | 143 ++------
 .../kafka/server/ReplicaAlterLogDirsManager.scala  |  12 +-
 .../kafka/server/ReplicaAlterLogDirsThread.scala   |  51 ++-
 .../scala/kafka/server/ReplicaFetcherManager.scala |  21 +-
 .../scala/kafka/server/ReplicaFetcherThread.scala  |  81 +++--
 .../main/scala/kafka/server/ReplicaManager.scala   | 335 +++++++++--------
 core/src/main/scala/kafka/utils/DelayedItem.scala  |   2 +-
 .../kafka/api/AdminClientIntegrationTest.scala     |  18 +-
 .../kafka/api/AuthorizerIntegrationTest.scala      |   4 +-
 .../integration/kafka/api/ConsumerBounceTest.scala |   2 +-
 .../kafka/server/DelayedFetchTest.scala            | 121 +++++++
 .../server/DynamicBrokerReconfigurationTest.scala  |   6 +-
 .../src/test/scala/other/kafka/StressTestLog.scala |   6 +-
 .../admin/ReassignPartitionsClusterTest.scala      |   7 +-
 .../scala/unit/kafka/cluster/PartitionTest.scala   | 398 ++++++++++++++++++--
 .../group/GroupMetadataManagerTest.scala           |  16 +-
 .../TransactionCoordinatorConcurrencyTest.scala    |   7 +-
 .../transaction/TransactionStateManagerTest.scala  |   7 +-
 .../kafka/integration/KafkaServerTestHarness.scala |   2 +-
 .../unit/kafka/log/BrokerCompressionTest.scala     |   8 +-
 .../test/scala/unit/kafka/log/LogManagerTest.scala |  14 +-
 core/src/test/scala/unit/kafka/log/LogTest.scala   |  56 +--
 .../kafka/server/AbstractFetcherManagerTest.scala  |  61 ++++
 .../kafka/server/AbstractFetcherThreadTest.scala   | 399 +++++++++++++++++----
 .../server/AlterReplicaLogDirsRequestTest.scala    |   2 +-
 .../scala/unit/kafka/server/FetchRequestTest.scala |  36 ++
 .../server/HighwatermarkPersistenceTest.scala      |   8 +-
 .../scala/unit/kafka/server/KafkaApisTest.scala    | 100 ++----
 .../unit/kafka/server/ListOffsetsRequestTest.scala |  40 ++-
 .../unit/kafka/server/LogDirFailureTest.scala      |   4 +-
 .../scala/unit/kafka/server/LogOffsetTest.scala    |  12 +-
 .../scala/unit/kafka/server/LogRecoveryTest.scala  |  12 +-
 .../server/OffsetsForLeaderEpochRequestTest.scala  |  44 ++-
 .../server/ReplicaAlterLogDirsThreadTest.scala     | 270 ++++++++------
 .../kafka/server/ReplicaFetcherThreadTest.scala    |  86 +++--
 .../kafka/server/ReplicaManagerQuotasTest.scala    |  77 ++--
 .../unit/kafka/server/ReplicaManagerTest.scala     |  82 +----
 .../scala/unit/kafka/server/RequestQuotaTest.scala |   4 +-
 .../scala/unit/kafka/server/SimpleFetchTest.scala  |  14 +-
 .../server/epoch/LeaderEpochIntegrationTest.scala  |   3 +-
 .../test/scala/unit/kafka/utils/TestUtils.scala    |  58 ++-
 60 files changed, 2448 insertions(+), 1146 deletions(-)
 copy clients/src/main/java/org/apache/kafka/common/errors/{InvalidTxnTimeoutException.java
=> FencedLeaderEpochException.java} (67%)
 copy clients/src/main/java/org/apache/kafka/common/errors/{LeaderNotAvailableException.java
=> UnknownLeaderEpochException.java} (68%)
 create mode 100644 core/src/test/scala/integration/kafka/server/DelayedFetchTest.scala
 create mode 100644 core/src/test/scala/unit/kafka/server/AbstractFetcherManagerTest.scala


Mime
View raw message