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 (cb91251 -> 90bbeed)
Date Wed, 01 Apr 2020 13:21:31 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 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


Mime
View raw message