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 (42b0971 -> 6dc6f6a)
Date Mon, 06 Jan 2020 18:51:35 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 42b0971  KAFKA-9364: Fix misleading consumer logs on throttling (#7894)
     add 6dc6f6a  KAFKA-9324: Drop support for Scala 2.11 (KIP-531) (#7859)

No new revisions were added by this update.

Summary of changes:
 README.md                                          |   2 +-
 build.gradle                                       |  45 +++--
 .../org/apache/kafka/common/utils/KafkaThread.java |   6 +-
 .../kafka/connect/runtime/ConnectMetrics.java      |  16 +-
 core/src/main/scala/kafka/admin/AclCommand.scala   |   6 +-
 core/src/main/scala/kafka/admin/AdminUtils.scala   |   2 +-
 .../kafka/admin/BrokerApiVersionsCommand.scala     |  30 ++--
 .../src/main/scala/kafka/admin/ConfigCommand.scala |   4 +-
 .../scala/kafka/admin/ConsumerGroupCommand.scala   |   4 +-
 .../scala/kafka/admin/DelegationTokenCommand.scala |   4 +-
 .../scala/kafka/admin/DeleteRecordsCommand.scala   |   8 +-
 .../scala/kafka/admin/LeaderElectionCommand.scala  |   4 +-
 .../main/scala/kafka/admin/LogDirsCommand.scala    |   4 +-
 .../PreferredReplicaLeaderElectionCommand.scala    |   5 +-
 .../kafka/admin/ReassignPartitionsCommand.scala    |   4 +-
 core/src/main/scala/kafka/admin/TopicCommand.scala |   4 +-
 core/src/main/scala/kafka/cluster/Partition.scala  |  68 +-------
 .../controller/ControllerChannelManager.scala      |  17 +-
 .../kafka/controller/ControllerEventManager.scala  |  10 +-
 .../scala/kafka/controller/KafkaController.scala   |  80 ++-------
 .../coordinator/group/GroupMetadataManager.scala   |  54 +++---
 .../TransactionMarkerChannelManager.scala          |  16 +-
 core/src/main/scala/kafka/log/LazyIndex.scala      |   2 +-
 core/src/main/scala/kafka/log/Log.scala            |  28 +---
 core/src/main/scala/kafka/log/LogCleaner.scala     |  37 ++---
 .../main/scala/kafka/log/LogCleanerManager.scala   |  58 +++----
 core/src/main/scala/kafka/log/LogManager.scala     |  31 ++--
 .../main/scala/kafka/network/RequestChannel.scala  |  18 +-
 .../main/scala/kafka/network/SocketServer.scala    |  98 ++++-------
 .../kafka/server/AbstractFetcherManager.scala      |  66 +++-----
 .../scala/kafka/server/AbstractFetcherThread.scala |  27 +--
 .../main/scala/kafka/server/DelayedFuture.scala    |   2 +-
 .../main/scala/kafka/server/DelayedOperation.scala |  19 +--
 .../src/main/scala/kafka/server/FetchSession.scala |  15 +-
 core/src/main/scala/kafka/server/KafkaServer.scala |  27 +--
 .../main/scala/kafka/server/ReplicaManager.scala   |  57 ++-----
 .../main/scala/kafka/tools/EndToEndLatency.scala   |   8 +-
 core/src/main/scala/kafka/tools/MirrorMaker.scala  |   6 +-
 .../kafka/tools/ReplicaVerificationTool.scala      |   2 +-
 core/src/main/scala/kafka/utils/CoreUtils.scala    |  42 +----
 .../main/scala/kafka/utils/KafkaScheduler.scala    |  10 +-
 core/src/main/scala/kafka/utils/Pool.scala         |   4 +-
 .../main/scala/kafka/utils/json/DecodeJson.scala   |  28 ++--
 core/src/main/scala/kafka/utils/timer/Timer.scala  |   8 +-
 core/src/main/scala/kafka/zk/ZkData.scala          |   9 +-
 .../scala/kafka/zookeeper/ZooKeeperClient.scala    |  79 +++++----
 .../AdminClientWithPoliciesIntegrationTest.scala   |   8 +-
 .../kafka/api/AuthorizerIntegrationTest.scala      |   4 +-
 .../kafka/api/BaseAdminIntegrationTest.scala       |   6 +-
 .../integration/kafka/api/ConsumerBounceTest.scala |   6 +-
 .../kafka/api/CustomQuotaCallbackTest.scala        |   4 +-
 .../DelegationTokenEndToEndAuthorizationTest.scala |   4 +-
 .../api/DescribeAuthorizedOperationsTest.scala     |   6 +-
 .../kafka/api/IntegrationTestHarness.scala         |   4 +-
 .../kafka/api/PlaintextAdminIntegrationTest.scala  |  98 +++++------
 .../SaslClientsWithInvalidCredentialsTest.scala    |   4 +-
 .../kafka/api/SaslSslAdminIntegrationTest.scala    |  16 +-
 .../kafka/api/SslAdminIntegrationTest.scala        |  25 ++-
 .../kafka/network/DynamicConnectionQuotaTest.scala |   8 +-
 .../server/DynamicBrokerReconfigurationTest.scala  |   2 +-
 .../scala/kafka/security/minikdc/MiniKdc.scala     |   4 +-
 .../scala/kafka/tools/LogCompactionTester.scala    |   8 +-
 .../scala/unit/kafka/admin/AclCommandTest.scala    |   2 +-
 .../kafka/admin/DelegationTokenCommandTest.scala   |   4 +-
 .../kafka/admin/LeaderElectionCommandTest.scala    |  10 +-
 .../admin/ReassignPartitionsClusterTest.scala      |   4 +-
 .../admin/TopicCommandWithAdminClientTest.scala    |   3 +-
 .../scala/unit/kafka/cluster/PartitionTest.scala   |  37 ++---
 .../transaction/ProducerIdManagerTest.scala        |  32 ++--
 .../TransactionCoordinatorConcurrencyTest.scala    |   6 +-
 .../transaction/TransactionCoordinatorTest.scala   | 179 +++++++-------------
 .../TransactionMarkerChannelManagerTest.scala      |  30 ++--
 ...sactionMarkerRequestCompletionHandlerTest.scala |  14 +-
 .../transaction/TransactionStateManagerTest.scala  |  22 +--
 .../MetricsDuringTopicCreationDeletionTest.scala   |  30 ++--
 .../integration/UncleanLeaderElectionTest.scala    |   4 +-
 .../test/scala/unit/kafka/log/LogManagerTest.scala |  22 +--
 .../unit/kafka/network/SocketServerTest.scala      |   6 +-
 .../security/authorizer/AclAuthorizerTest.scala    |   4 +-
 .../DelegationTokenRequestsOnPlainTextTest.scala   |   4 +-
 .../kafka/server/DelegationTokenRequestsTest.scala |   4 +-
 ...nTokenRequestsWithDisableTokenFeatureTest.scala |   4 +-
 .../scala/unit/kafka/server/KafkaApisTest.scala    |  16 +-
 .../unit/kafka/server/LogDirFailureTest.scala      |   2 +-
 .../server/ReplicaAlterLogDirsThreadTest.scala     |  18 +-
 .../scala/unit/kafka/utils/MockScheduler.scala     |   6 +-
 .../test/scala/unit/kafka/utils/TestUtils.scala    |   2 +-
 docs/streams/developer-guide/dsl-api.html          |   2 +-
 docs/streams/developer-guide/write-streams.html    |   2 +-
 docs/upgrade.html                                  |   3 +
 gradle/dependencies.gradle                         |  11 +-
 .../kafka/streams/scala/FunctionConversions.scala  |  61 ++-----
 .../streams/scala/FunctionsCompatConversions.scala | 113 +++++--------
 .../streams/scala/kstream/KGroupedStream.scala     |   2 -
 .../streams/scala/kstream/KGroupedTable.scala      |   2 -
 .../kafka/streams/scala/kstream/KStream.scala      |   5 +-
 .../kafka/streams/scala/kstream/Suppressed.scala   |   6 +-
 ...bleJoinScalaIntegrationTestImplicitSerdes.scala |  45 ++---
 .../apache/kafka/streams/scala/TopologyTest.scala  | 181 +++++++--------------
 .../apache/kafka/streams/scala/WordCountTest.scala |  29 ++--
 .../kafka/streams/scala/kstream/KStreamTest.scala  |  11 +-
 .../kafka/streams/scala/kstream/KTableTest.scala   |  14 +-
 .../streams/scala/kstream/SuppressedTest.scala     |   3 +-
 .../workload/SustainedConnectionWorker.java        |   6 +-
 104 files changed, 776 insertions(+), 1466 deletions(-)


Mime
View raw message