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/04/01 13:21:31 UTC
[kafka] branch trunk updated (cb91251 -> 90bbeed)
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 cb91251 MINOR: reduce garbage in operation and resource java conversions (#8391)
add 90bbeed MINOR: Fix Scala 2.13 compiler warnings (#8390)
No new revisions were added by this update.
Summary of changes:
build.gradle | 1 +
.../kafka/common/requests/ListOffsetRequest.java | 3 +-
.../kafka/common/requests/ListOffsetResponse.java | 2 -
.../kafka/common/requests/OffsetCommitRequest.java | 4 +-
.../apache/kafka/common/utils/SecurityUtils.java | 5 +-
.../apache/kafka/common/message/MessageTest.java | 4 +-
.../kafka/connect/runtime/ConnectorConfig.java | 2 +-
.../kafka/connect/runtime/AbstractHerderTest.java | 4 +-
.../resources/ConnectorPluginsResourceTest.java | 2 +-
core/src/main/scala/kafka/Kafka.scala | 2 +-
core/src/main/scala/kafka/admin/AclCommand.scala | 12 +++--
.../kafka/admin/BrokerApiVersionsCommand.scala | 2 +-
.../src/main/scala/kafka/admin/ConfigCommand.scala | 3 +-
.../scala/kafka/admin/ConsumerGroupCommand.scala | 41 +++++++-------
.../scala/kafka/admin/DelegationTokenCommand.scala | 2 +-
.../scala/kafka/admin/DeleteRecordsCommand.scala | 2 +-
.../scala/kafka/admin/LeaderElectionCommand.scala | 2 +-
.../main/scala/kafka/admin/LogDirsCommand.scala | 4 +-
.../PreferredReplicaLeaderElectionCommand.scala | 2 +-
.../kafka/admin/ReassignPartitionsCommand.scala | 34 ++++++------
core/src/main/scala/kafka/admin/TopicCommand.scala | 4 +-
.../scala/kafka/admin/ZkSecurityMigrator.scala | 2 +-
core/src/main/scala/kafka/api/package.scala | 2 +-
core/src/main/scala/kafka/cluster/Broker.scala | 2 +-
core/src/main/scala/kafka/cluster/Cluster.scala | 45 ----------------
core/src/main/scala/kafka/cluster/Partition.scala | 8 ++-
.../scala/kafka/common/InterBrokerSendThread.scala | 2 +-
.../controller/ControllerChannelManager.scala | 47 ++++++++--------
.../scala/kafka/controller/ControllerContext.scala | 59 +++++++++++---------
.../kafka/controller/ControllerEventManager.scala | 2 +-
.../scala/kafka/controller/KafkaController.scala | 33 ++++++------
.../kafka/controller/PartitionStateMachine.scala | 2 +-
.../kafka/controller/ReplicaStateMachine.scala | 31 ++++-------
.../kafka/controller/TopicDeletionManager.scala | 4 +-
.../kafka/coordinator/group/GroupCoordinator.scala | 12 ++---
.../kafka/coordinator/group/GroupMetadata.scala | 20 ++++---
.../coordinator/group/GroupMetadataManager.scala | 14 ++---
.../transaction/ProducerIdManager.scala | 2 +-
.../transaction/TransactionCoordinator.scala | 12 ++---
.../TransactionMarkerChannelManager.scala | 2 +-
...TransactionMarkerRequestCompletionHandler.scala | 2 +-
.../transaction/TransactionStateManager.scala | 10 ++--
core/src/main/scala/kafka/log/Log.scala | 8 +--
core/src/main/scala/kafka/log/LogCleaner.scala | 24 ++++-----
.../main/scala/kafka/log/LogCleanerManager.scala | 2 +-
core/src/main/scala/kafka/log/LogConfig.scala | 2 +-
core/src/main/scala/kafka/log/LogManager.scala | 6 +--
core/src/main/scala/kafka/log/LogSegment.scala | 2 +-
core/src/main/scala/kafka/log/LogValidator.scala | 2 +-
core/src/main/scala/kafka/log/OffsetIndex.scala | 2 +-
.../scala/kafka/log/ProducerStateManager.scala | 6 +--
core/src/main/scala/kafka/log/TimeIndex.scala | 2 +-
.../main/scala/kafka/network/RequestChannel.scala | 2 +-
.../main/scala/kafka/network/SocketServer.scala | 4 +-
.../main/scala/kafka/security/auth/Resource.scala | 2 +-
.../kafka/security/auth/SimpleAclAuthorizer.scala | 2 +-
.../kafka/security/authorizer/AclAuthorizer.scala | 29 +++++-----
.../scala/kafka/security/authorizer/AclEntry.scala | 2 +-
.../security/authorizer/AuthorizerWrapper.scala | 4 +-
.../scala/kafka/server/AbstractFetcherThread.scala | 2 +-
.../src/main/scala/kafka/server/AdminManager.scala | 9 ++--
.../kafka/server/BrokerMetadataCheckpoint.scala | 2 +-
.../scala/kafka/server/ClientQuotaManager.scala | 11 ++--
.../kafka/server/ClientRequestQuotaManager.scala | 2 +-
.../main/scala/kafka/server/ConfigHandler.scala | 12 ++---
.../scala/kafka/server/DelayedElectLeader.scala | 4 +-
.../kafka/server/DelegationTokenManager.scala | 2 +-
.../scala/kafka/server/DynamicBrokerConfig.scala | 62 +++++++++++++---------
.../main/scala/kafka/server/DynamicConfig.scala | 2 +-
.../scala/kafka/server/DynamicConfigManager.scala | 2 +-
.../src/main/scala/kafka/server/FetchSession.scala | 2 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 51 +++++++++---------
core/src/main/scala/kafka/server/KafkaConfig.scala | 4 +-
.../scala/kafka/server/KafkaRequestHandler.scala | 2 +-
core/src/main/scala/kafka/server/KafkaServer.scala | 12 +++--
.../main/scala/kafka/server/MetadataCache.scala | 4 +-
.../kafka/server/ReplicaAlterLogDirsThread.scala | 2 +-
.../kafka/server/ReplicaFetcherBlockingSend.scala | 2 +-
.../scala/kafka/server/ReplicaFetcherThread.scala | 2 +-
.../main/scala/kafka/server/ReplicaManager.scala | 12 ++---
.../kafka/server/ReplicationQuotaManager.scala | 2 +-
.../main/scala/kafka/tools/ConsoleConsumer.scala | 2 +-
.../main/scala/kafka/tools/ConsoleProducer.scala | 2 +-
.../scala/kafka/tools/ConsumerPerformance.scala | 4 +-
.../main/scala/kafka/tools/DumpLogSegments.scala | 2 +-
.../main/scala/kafka/tools/EndToEndLatency.scala | 4 +-
.../main/scala/kafka/tools/GetOffsetShell.scala | 4 +-
core/src/main/scala/kafka/tools/JmxTool.scala | 6 +--
core/src/main/scala/kafka/tools/MirrorMaker.scala | 4 +-
.../kafka/tools/ReplicaVerificationTool.scala | 18 +++----
core/src/main/scala/kafka/utils/CoreUtils.scala | 2 +-
core/src/main/scala/kafka/utils/Implicits.scala | 2 +-
core/src/main/scala/kafka/utils/Json.scala | 2 +-
.../main/scala/kafka/utils/Log4jController.scala | 2 +-
core/src/main/scala/kafka/utils/Pool.scala | 6 +--
.../scala/kafka/utils/VerifiableProperties.scala | 2 +-
.../main/scala/kafka/utils/json/DecodeJson.scala | 6 +--
.../main/scala/kafka/utils/json/JsonArray.scala | 4 +-
.../main/scala/kafka/utils/json/JsonObject.scala | 2 +-
core/src/main/scala/kafka/zk/AdminZkClient.scala | 7 +--
core/src/main/scala/kafka/zk/KafkaZkClient.scala | 6 +--
core/src/main/scala/kafka/zk/ZkData.scala | 6 +--
.../scala/kafka/zookeeper/ZooKeeperClient.scala | 2 +-
.../ZooKeeperMainWithTlsSupportForKafka.scala | 4 +-
.../admin/ReassignPartitionsIntegrationTest.scala | 2 +-
.../kafka/api/AbstractConsumerTest.scala | 6 +--
.../AdminClientWithPoliciesIntegrationTest.scala | 2 +-
.../kafka/api/AuthorizerIntegrationTest.scala | 2 +-
.../kafka/api/BaseAdminIntegrationTest.scala | 2 +-
.../integration/kafka/api/BaseConsumerTest.scala | 2 +-
.../kafka/api/BaseProducerSendTest.scala | 2 +-
.../integration/kafka/api/BaseQuotaTest.scala | 10 ++--
.../integration/kafka/api/ConsumerBounceTest.scala | 2 +-
.../kafka/api/CustomQuotaCallbackTest.scala | 8 +--
.../DelegationTokenEndToEndAuthorizationTest.scala | 2 +-
.../api/DescribeAuthorizedOperationsTest.scala | 2 +-
.../kafka/api/EndToEndAuthorizationTest.scala | 4 +-
.../kafka/api/EndToEndClusterIdTest.scala | 2 +-
.../kafka/api/GroupAuthorizerIntegrationTest.scala | 4 +-
.../api/GroupCoordinatorIntegrationTest.scala | 2 +-
.../scala/integration/kafka/api/MetricsTest.scala | 2 +-
.../kafka/api/PlaintextAdminIntegrationTest.scala | 10 ++--
.../kafka/api/PlaintextConsumerTest.scala | 8 +--
.../kafka/api/ProducerCompressionTest.scala | 2 +-
.../SaslClientsWithInvalidCredentialsTest.scala | 2 +-
.../kafka/api/SaslEndToEndAuthorizationTest.scala | 2 +-
.../kafka/api/SaslMultiMechanismConsumerTest.scala | 2 +-
.../SaslScramSslEndToEndAuthorizationTest.scala | 2 +-
.../kafka/api/SaslSslAdminIntegrationTest.scala | 2 +-
.../kafka/api/SslAdminIntegrationTest.scala | 2 +-
.../kafka/api/TransactionsBounceTest.scala | 2 +-
.../kafka/api/TransactionsExpirationTest.scala | 2 +-
.../integration/kafka/api/TransactionsTest.scala | 2 +-
.../kafka/network/DynamicConnectionQuotaTest.scala | 4 +-
.../server/DynamicBrokerReconfigurationTest.scala | 23 ++++++--
.../kafka/server/GssapiAuthenticationTest.scala | 2 +-
.../kafka/server/ScramServerStartupTest.scala | 2 +-
.../scala/kafka/security/minikdc/MiniKdc.scala | 2 +-
.../scala/kafka/tools/LogCompactionTester.scala | 4 +-
.../test/scala/kafka/zk/LiteralAclStoreTest.scala | 4 +-
.../other/kafka/ReplicationQuotasTestRig.scala | 10 ++--
.../scala/other/kafka/TestLinearWriteSpeed.scala | 2 +-
.../other/kafka/TestPurgatoryPerformance.scala | 2 +-
.../test/scala/unit/kafka/KafkaConfigTest.scala | 2 +-
.../scala/unit/kafka/admin/AddPartitionsTest.scala | 10 ++--
.../unit/kafka/admin/AdminRackAwareTest.scala | 2 +-
.../scala/unit/kafka/admin/ConfigCommandTest.scala | 2 +-
.../kafka/admin/ConsumerGroupCommandTest.scala | 6 +--
.../kafka/admin/DelegationTokenCommandTest.scala | 2 +-
.../scala/unit/kafka/admin/DeleteTopicTest.scala | 4 +-
.../kafka/admin/LeaderElectionCommandTest.scala | 2 +-
...PreferredReplicaLeaderElectionCommandTest.scala | 4 +-
.../kafka/admin/ReassignPartitionsUnitTest.scala | 45 ++++++++--------
.../kafka/admin/ResetConsumerGroupOffsetTest.scala | 27 +++++-----
.../admin/TopicCommandWithAdminClientTest.scala | 2 +-
.../unit/kafka/cluster/AssignmentStateTest.scala | 3 +-
.../unit/kafka/cluster/PartitionLockTest.scala | 3 +-
.../scala/unit/kafka/cluster/PartitionTest.scala | 4 +-
.../controller/ControllerChannelManagerTest.scala | 4 +-
.../kafka/controller/ControllerContextTest.scala | 2 +-
.../controller/ControllerEventManagerTest.scala | 16 +++---
.../controller/ControllerIntegrationTest.scala | 15 +++---
.../controller/PartitionStateMachineTest.scala | 22 ++++----
.../kafka/controller/ReplicaStateMachineTest.scala | 6 +--
.../controller/TopicDeletionManagerTest.scala | 6 +--
.../AbstractCoordinatorConcurrencyTest.scala | 2 +-
.../coordinator/group/GroupCoordinatorTest.scala | 2 +-
.../group/GroupMetadataManagerTest.scala | 2 +-
.../coordinator/group/GroupMetadataTest.scala | 2 +-
.../TransactionCoordinatorConcurrencyTest.scala | 2 +-
.../transaction/TransactionLogTest.scala | 2 +-
.../TransactionMarkerChannelManagerTest.scala | 14 ++---
.../transaction/TransactionMetadataTest.scala | 39 ++++++++------
.../transaction/TransactionStateManagerTest.scala | 2 +-
.../MetricsDuringTopicCreationDeletionTest.scala | 4 +-
.../integration/UncleanLeaderElectionTest.scala | 17 ++++--
.../unit/kafka/log/BrokerCompressionTest.scala | 2 +-
.../unit/kafka/log/LogCleanerIntegrationTest.scala | 7 ++-
.../kafka/log/LogCleanerLagIntegrationTest.scala | 3 +-
.../unit/kafka/log/LogCleanerManagerTest.scala | 4 +-
.../LogCleanerParameterizedIntegrationTest.scala | 2 +-
.../test/scala/unit/kafka/log/LogCleanerTest.scala | 4 +-
.../test/scala/unit/kafka/log/LogSegmentTest.scala | 2 +-
core/src/test/scala/unit/kafka/log/LogTest.scala | 12 ++---
.../scala/unit/kafka/log/LogValidatorTest.scala | 3 +-
.../test/scala/unit/kafka/log/OffsetMapTest.scala | 2 +-
.../scala/unit/kafka/metrics/MetricsTest.scala | 2 +-
.../unit/kafka/network/RequestChannelTest.scala | 2 +-
.../unit/kafka/network/SocketServerTest.scala | 11 ++--
.../kafka/security/auth/ZkAuthorizationTest.scala | 4 +-
.../security/authorizer/AclAuthorizerTest.scala | 2 +-
.../kafka/security/authorizer/AclEntryTest.scala | 2 +-
.../delegation/DelegationTokenManagerTest.scala | 2 +-
.../server/AbstractApiVersionsRequestTest.scala | 2 +-
.../server/AbstractCreateTopicsRequestTest.scala | 2 +-
.../kafka/server/AbstractFetcherManagerTest.scala | 4 +-
.../kafka/server/AbstractFetcherThreadTest.scala | 4 +-
.../server/AddPartitionsToTxnRequestTest.scala | 2 +-
.../server/AlterReplicaLogDirsRequestTest.scala | 2 +-
.../kafka/server/BrokerEpochIntegrationTest.scala | 4 +-
.../unit/kafka/server/ClientQuotaManagerTest.scala | 7 +--
.../kafka/server/ClientQuotasRequestTest.scala | 6 +--
.../kafka/server/CreateTopicsRequestTest.scala | 2 +-
.../server/CreateTopicsRequestWithPolicyTest.scala | 2 +-
.../unit/kafka/server/DelayedOperationTest.scala | 2 +-
.../DelegationTokenRequestsOnPlainTextTest.scala | 2 +-
.../kafka/server/DelegationTokenRequestsTest.scala | 2 +-
...nTokenRequestsWithDisableTokenFeatureTest.scala | 2 +-
.../kafka/server/DeleteTopicsRequestTest.scala | 2 +-
.../kafka/server/DynamicBrokerConfigTest.scala | 2 +-
.../kafka/server/DynamicConfigChangeTest.scala | 2 +-
.../unit/kafka/server/EdgeCaseRequestTest.scala | 2 +-
.../kafka/server/FetchRequestMaxBytesTest.scala | 2 +-
.../scala/unit/kafka/server/FetchRequestTest.scala | 2 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 2 +-
.../unit/kafka/server/LeaderElectionTest.scala | 4 +-
.../unit/kafka/server/ListOffsetsRequestTest.scala | 2 +-
.../unit/kafka/server/LogDirFailureTest.scala | 2 +-
.../scala/unit/kafka/server/LogOffsetTest.scala | 2 +-
.../unit/kafka/server/MetadataCacheTest.scala | 2 +-
.../unit/kafka/server/MetadataRequestTest.scala | 2 +-
.../server/OffsetsForLeaderEpochRequestTest.scala | 2 +-
.../unit/kafka/server/ProduceRequestTest.scala | 2 +-
.../server/ReplicaAlterLogDirsThreadTest.scala | 2 +-
.../kafka/server/ReplicaFetcherThreadTest.scala | 2 +-
.../kafka/server/ReplicaManagerQuotasTest.scala | 2 +-
.../unit/kafka/server/ReplicaManagerTest.scala | 2 +-
.../kafka/server/ReplicationQuotaManagerTest.scala | 2 +-
.../unit/kafka/server/ReplicationQuotasTest.scala | 4 +-
.../scala/unit/kafka/server/RequestQuotaTest.scala | 2 +-
.../unit/kafka/server/ServerShutdownTest.scala | 4 +-
.../unit/kafka/server/ServerStartupTest.scala | 2 +-
.../unit/kafka/server/StopReplicaRequestTest.scala | 2 +-
...chDrivenReplicationProtocolAcceptanceTest.scala | 2 +-
.../server/epoch/LeaderEpochIntegrationTest.scala | 7 +--
.../unit/kafka/tools/ConsoleConsumerTest.scala | 2 +-
.../scala/unit/kafka/tools/MirrorMakerTest.scala | 2 +-
.../scala/unit/kafka/utils/CoreUtilsTest.scala | 4 +-
.../src/test/scala/unit/kafka/utils/JsonTest.scala | 9 ++--
.../test/scala/unit/kafka/utils/TestUtils.scala | 29 ++--------
.../scala/unit/kafka/zk/AdminZkClientTest.scala | 4 +-
.../scala/unit/kafka/zk/KafkaZkClientTest.scala | 9 ++--
.../kafka/zk/ReassignPartitionsZNodeTest.scala | 10 ++--
.../scala/unit/kafka/zk/ZooKeeperTestHarness.scala | 2 +-
.../unit/kafka/zookeeper/ZooKeeperClientTest.scala | 16 +-----
gradle/dependencies.gradle | 2 +-
gradle/spotbugs-exclude.xml | 7 +++
.../streams/kstream/internals/KStreamImplTest.java | 2 +-
.../streams/kstream/internals/KTableImplTest.java | 6 +--
.../kstream/internals/KTableMapValuesTest.java | 8 +--
...sToDbOptionsColumnFamilyOptionsAdapterTest.java | 4 +-
.../kafka/streams/scala/FunctionConversions.scala | 2 +-
.../streams/scala/FunctionsCompatConversions.scala | 2 +-
.../kafka/streams/scala/ImplicitConversions.scala | 2 -
.../kafka/streams/scala/StreamsBuilder.scala | 2 +-
.../kafka/streams/scala/kstream/KStream.scala | 2 +-
.../apache/kafka/streams/scala/TopologyTest.scala | 2 +-
.../apache/kafka/streams/scala/WordCountTest.scala | 8 +--
...StreamToTableJoinScalaIntegrationTestBase.scala | 2 +-
259 files changed, 780 insertions(+), 815 deletions(-)
delete mode 100644 core/src/main/scala/kafka/cluster/Cluster.scala