You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2020/01/06 18:51:35 UTC
[kafka] branch trunk updated (42b0971 -> 6dc6f6a)
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(-)