[kafka] branch trunk updated (788793dee6f -> 1d3fb760926)

[sa...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

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


    from 788793dee6f KAFKA-10575: Add onRestoreSuspsnded to StateRestoreListener (#13179)
     add 1d3fb760926 KAFKA-14688 Move package org.apache.kafka.server.log.internals to org.apache.kafka.storage.internals.log (#13213)

No new revisions were added by this update.

Summary of changes:
 build.gradle                                                      | 2 +-
 checkstyle/import-control-jmh-benchmarks.xml                      | 1 +
 core/src/main/java/kafka/server/builders/LogManagerBuilder.java   | 6 +++---
 .../main/java/kafka/server/builders/ReplicaManagerBuilder.java    | 2 +-
 core/src/main/scala/kafka/admin/ConfigCommand.scala               | 2 +-
 core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala   | 2 +-
 core/src/main/scala/kafka/admin/TopicCommand.scala                | 2 +-
 core/src/main/scala/kafka/cluster/Partition.scala                 | 2 +-
 core/src/main/scala/kafka/cluster/Replica.scala                   | 2 +-
 .../main/scala/kafka/coordinator/group/GroupMetadataManager.scala | 2 +-
 .../kafka/coordinator/transaction/TransactionStateManager.scala   | 2 +-
 core/src/main/scala/kafka/log/LocalLog.scala                      | 4 ++--
 core/src/main/scala/kafka/log/LogCleaner.scala                    | 2 +-
 core/src/main/scala/kafka/log/LogCleanerManager.scala             | 2 +-
 core/src/main/scala/kafka/log/LogLoader.scala                     | 2 +-
 core/src/main/scala/kafka/log/LogManager.scala                    | 4 ++--
 core/src/main/scala/kafka/log/LogSegment.scala                    | 2 +-
 core/src/main/scala/kafka/log/ProducerStateManager.scala          | 2 +-
 core/src/main/scala/kafka/log/UnifiedLog.scala                    | 2 +-
 core/src/main/scala/kafka/log/remote/RemoteIndexCache.scala       | 2 +-
 core/src/main/scala/kafka/raft/KafkaMetadataLog.scala             | 5 +++--
 core/src/main/scala/kafka/server/BrokerServer.scala               | 2 +-
 core/src/main/scala/kafka/server/ConfigHandler.scala              | 4 ++--
 core/src/main/scala/kafka/server/ConfigHelper.scala               | 2 +-
 .../scala/kafka/server/ControllerConfigurationValidator.scala     | 2 +-
 core/src/main/scala/kafka/server/DelayedFetch.scala               | 2 +-
 core/src/main/scala/kafka/server/DynamicBrokerConfig.scala        | 2 +-
 core/src/main/scala/kafka/server/DynamicConfig.scala              | 2 +-
 core/src/main/scala/kafka/server/KafkaApis.scala                  | 2 +-
 core/src/main/scala/kafka/server/KafkaConfig.scala                | 4 ++--
 core/src/main/scala/kafka/server/KafkaRaftServer.scala            | 2 +-
 core/src/main/scala/kafka/server/KafkaServer.scala                | 2 +-
 core/src/main/scala/kafka/server/LocalLeaderEndPoint.scala        | 2 +-
 core/src/main/scala/kafka/server/PartitionMetadataFile.scala      | 2 +-
 core/src/main/scala/kafka/server/ReplicaFetcherThread.scala       | 2 +-
 core/src/main/scala/kafka/server/ReplicaManager.scala             | 2 +-
 core/src/main/scala/kafka/server/ZkAdminManager.scala             | 2 +-
 .../scala/kafka/server/checkpoints/OffsetCheckpointFile.scala     | 2 +-
 core/src/main/scala/kafka/tools/DumpLogSegments.scala             | 2 +-
 core/src/main/scala/kafka/zk/AdminZkClient.scala                  | 2 +-
 core/src/main/scala/kafka/zk/KafkaZkClient.scala                  | 2 +-
 .../kafka/api/AdminClientWithPoliciesIntegrationTest.scala        | 2 +-
 .../integration/kafka/api/PlaintextAdminIntegrationTest.scala     | 2 +-
 .../scala/integration/kafka/api/PlaintextProducerSendTest.scala   | 2 +-
 .../scala/integration/kafka/api/SaslSslAdminIntegrationTest.scala | 2 +-
 .../test/scala/integration/kafka/server/DelayedFetchTest.scala    | 2 +-
 .../kafka/server/DynamicBrokerReconfigurationTest.scala           | 2 +-
 core/src/test/scala/kafka/raft/KafkaMetadataLogTest.scala         | 2 +-
 core/src/test/scala/kafka/server/LocalLeaderEndPointTest.scala    | 2 +-
 core/src/test/scala/other/kafka/StressTestLog.scala               | 2 +-
 core/src/test/scala/other/kafka/TestLinearWriteSpeed.scala        | 2 +-
 core/src/test/scala/unit/kafka/admin/ReplicationQuotaUtils.scala  | 2 +-
 .../src/test/scala/unit/kafka/cluster/AbstractPartitionTest.scala | 2 +-
 core/src/test/scala/unit/kafka/cluster/PartitionLockTest.scala    | 2 +-
 core/src/test/scala/unit/kafka/cluster/PartitionTest.scala        | 2 +-
 core/src/test/scala/unit/kafka/cluster/ReplicaTest.scala          | 2 +-
 .../scala/unit/kafka/controller/PartitionStateMachineTest.scala   | 2 +-
 .../kafka/coordinator/AbstractCoordinatorConcurrencyTest.scala    | 2 +-
 .../scala/unit/kafka/coordinator/group/GroupCoordinatorTest.scala | 2 +-
 .../unit/kafka/coordinator/group/GroupMetadataManagerTest.scala   | 2 +-
 .../transaction/TransactionCoordinatorConcurrencyTest.scala       | 2 +-
 .../coordinator/transaction/TransactionStateManagerTest.scala     | 2 +-
 .../scala/unit/kafka/log/AbstractLogCleanerIntegrationTest.scala  | 2 +-
 core/src/test/scala/unit/kafka/log/BrokerCompressionTest.scala    | 2 +-
 core/src/test/scala/unit/kafka/log/LocalLogTest.scala             | 4 ++--
 core/src/test/scala/unit/kafka/log/LogCleanerManagerTest.scala    | 2 +-
 .../unit/kafka/log/LogCleanerParameterizedIntegrationTest.scala   | 2 +-
 core/src/test/scala/unit/kafka/log/LogCleanerTest.scala           | 2 +-
 core/src/test/scala/unit/kafka/log/LogConcurrencyTest.scala       | 2 +-
 core/src/test/scala/unit/kafka/log/LogConfigTest.scala            | 2 +-
 core/src/test/scala/unit/kafka/log/LogLoaderTest.scala            | 2 +-
 core/src/test/scala/unit/kafka/log/LogManagerTest.scala           | 2 +-
 core/src/test/scala/unit/kafka/log/LogSegmentTest.scala           | 2 +-
 core/src/test/scala/unit/kafka/log/LogTestUtils.scala             | 2 +-
 core/src/test/scala/unit/kafka/log/LogValidatorTest.scala         | 4 ++--
 core/src/test/scala/unit/kafka/log/OffsetIndexTest.scala          | 2 +-
 core/src/test/scala/unit/kafka/log/OffsetMapTest.scala            | 2 +-
 core/src/test/scala/unit/kafka/log/ProducerStateManagerTest.scala | 2 +-
 core/src/test/scala/unit/kafka/log/TimeIndexTest.scala            | 2 +-
 core/src/test/scala/unit/kafka/log/TransactionIndexTest.scala     | 2 +-
 core/src/test/scala/unit/kafka/log/UnifiedLogTest.scala           | 2 +-
 .../test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala   | 2 +-
 .../test/scala/unit/kafka/log/remote/RemoteLogManagerTest.scala   | 2 +-
 .../test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala  | 2 +-
 .../test/scala/unit/kafka/server/DynamicBrokerConfigTest.scala    | 2 +-
 .../test/scala/unit/kafka/server/DynamicConfigChangeTest.scala    | 2 +-
 .../scala/unit/kafka/server/HighwatermarkPersistenceTest.scala    | 2 +-
 core/src/test/scala/unit/kafka/server/IsrExpirationTest.scala     | 2 +-
 core/src/test/scala/unit/kafka/server/KafkaApisTest.scala         | 2 +-
 core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala       | 2 +-
 .../scala/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala   | 2 +-
 .../scala/unit/kafka/server/ReplicaManagerConcurrencyTest.scala   | 2 +-
 .../test/scala/unit/kafka/server/ReplicaManagerQuotasTest.scala   | 2 +-
 core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala    | 2 +-
 core/src/test/scala/unit/kafka/server/ReplicationQuotasTest.scala | 2 +-
 .../LeaderEpochCheckpointFileWithFailureHandlerTest.scala         | 2 +-
 .../checkpoints/OffsetCheckpointFileWithFailureHandlerTest.scala  | 2 +-
 .../epoch/EpochDrivenReplicationProtocolAcceptanceTest.scala      | 2 +-
 .../scala/unit/kafka/server/epoch/LeaderEpochFileCacheTest.scala  | 2 +-
 .../scala/unit/kafka/server/epoch/OffsetsForLeaderEpochTest.scala | 2 +-
 core/src/test/scala/unit/kafka/tools/DumpLogSegmentsTest.scala    | 2 +-
 core/src/test/scala/unit/kafka/utils/SchedulerTest.scala          | 2 +-
 core/src/test/scala/unit/kafka/utils/TestUtils.scala              | 2 +-
 core/src/test/scala/unit/kafka/zk/AdminZkClientTest.scala         | 2 +-
 core/src/test/scala/unit/kafka/zk/KafkaZkClientTest.scala         | 2 +-
 gradle/spotbugs-exclude.xml                                       | 2 +-
 .../apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java   | 6 +++---
 .../kafka/jmh/partition/PartitionMakeFollowerBenchmark.java       | 6 +++---
 .../kafka/jmh/partition/UpdateFollowerFetchStateBenchmark.java    | 8 ++++----
 .../org/apache/kafka/jmh/record/BaseRecordBatchBenchmark.java     | 2 +-
 .../jmh/record/CompressedRecordBatchValidationBenchmark.java      | 4 ++--
 .../jmh/record/UncompressedRecordBatchValidationBenchmark.java    | 4 ++--
 .../main/java/org/apache/kafka/jmh/server/CheckpointBench.java    | 6 +++---
 .../java/org/apache/kafka/jmh/server/PartitionCreationBench.java  | 6 +++---
 .../storage/ClassLoaderAwareRemoteLogMetadataManager.java         | 2 +-
 .../log/remote/storage/ClassLoaderAwareRemoteStorageManager.java  | 2 +-
 .../internals/checkpoint/CheckpointFileWithFailureHandler.java    | 2 +-
 .../kafka/storage/internals/checkpoint/LeaderEpochCheckpoint.java | 2 +-
 .../storage/internals/checkpoint/LeaderEpochCheckpointFile.java   | 4 ++--
 .../kafka/storage/internals/epoch/LeaderEpochFileCache.java       | 2 +-
 .../log/internals => storage/internals/log}/AbortedTxn.java       | 2 +-
 .../log/internals => storage/internals/log}/AbstractIndex.java    | 2 +-
 .../log/internals => storage/internals/log}/AppendOrigin.java     | 2 +-
 .../log/internals => storage/internals/log}/BatchMetadata.java    | 2 +-
 .../log/internals => storage/internals/log}/CleanerConfig.java    | 2 +-
 .../log/internals => storage/internals/log}/CompletedTxn.java     | 2 +-
 .../internals/log}/CorruptIndexException.java                     | 2 +-
 .../internals/log}/CorruptSnapshotException.java                  | 2 +-
 .../log/internals => storage/internals/log}/EpochEntry.java       | 2 +-
 .../log/internals => storage/internals/log}/FetchDataInfo.java    | 2 +-
 .../log/internals => storage/internals/log}/FetchIsolation.java   | 2 +-
 .../log/internals => storage/internals/log}/FetchParams.java      | 2 +-
 .../internals => storage/internals/log}/FetchPartitionData.java   | 2 +-
 .../log/internals => storage/internals/log}/IndexEntry.java       | 2 +-
 .../internals/log}/IndexOffsetOverflowException.java              | 2 +-
 .../log/internals => storage/internals/log}/IndexSearchType.java  | 2 +-
 .../log/internals => storage/internals/log}/LastRecord.java       | 2 +-
 .../log/internals => storage/internals/log}/LazyIndex.java        | 2 +-
 .../log/internals => storage/internals/log}/LoadedLogOffsets.java | 2 +-
 .../log/internals => storage/internals/log}/LogConfig.java        | 2 +-
 .../internals => storage/internals/log}/LogDirFailureChannel.java | 2 +-
 .../log/internals => storage/internals/log}/LogFileUtils.java     | 2 +-
 .../internals => storage/internals/log}/LogOffsetMetadata.java    | 2 +-
 .../log/internals => storage/internals/log}/LogValidator.java     | 2 +-
 .../log/internals => storage/internals/log}/OffsetIndex.java      | 2 +-
 .../log/internals => storage/internals/log}/OffsetMap.java        | 2 +-
 .../log/internals => storage/internals/log}/OffsetPosition.java   | 2 +-
 .../internals => storage/internals/log}/ProducerAppendInfo.java   | 2 +-
 .../internals => storage/internals/log}/ProducerStateEntry.java   | 2 +-
 .../internals/log}/RecordValidationException.java                 | 2 +-
 .../log/internals => storage/internals/log}/SkimpyOffsetMap.java  | 2 +-
 .../log/internals => storage/internals/log}/SnapshotFile.java     | 4 ++--
 .../log/internals => storage/internals/log}/StorageAction.java    | 2 +-
 .../internals/log}/ThrottledReplicaListValidator.java             | 2 +-
 .../log/internals => storage/internals/log}/TimeIndex.java        | 2 +-
 .../log/internals => storage/internals/log}/TimestampOffset.java  | 2 +-
 .../log/internals => storage/internals/log}/TransactionIndex.java | 2 +-
 .../internals => storage/internals/log}/TxnIndexSearchResult.java | 2 +-
 .../log/internals => storage/internals/log}/TxnMetadata.java      | 2 +-
 159 files changed, 184 insertions(+), 182 deletions(-)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/AbortedTxn.java (98%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/AbstractIndex.java (99%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/AppendOrigin.java (97%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/BatchMetadata.java (98%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/CleanerConfig.java (98%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/CompletedTxn.java (98%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/CorruptIndexException.java (95%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/CorruptSnapshotException.java (95%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/EpochEntry.java (97%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/FetchDataInfo.java (97%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/FetchIsolation.java (96%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/FetchParams.java (98%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/FetchPartitionData.java (98%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/IndexEntry.java (94%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/IndexOffsetOverflowException.java (96%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/IndexSearchType.java (94%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/LastRecord.java (97%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/LazyIndex.java (99%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/LoadedLogOffsets.java (98%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/LogConfig.java (99%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/LogDirFailureChannel.java (98%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/LogFileUtils.java (96%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/LogOffsetMetadata.java (98%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/LogValidator.java (99%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/OffsetIndex.java (99%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/OffsetMap.java (96%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/OffsetPosition.java (97%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/ProducerAppendInfo.java (99%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/ProducerStateEntry.java (99%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/RecordValidationException.java (97%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/SkimpyOffsetMap.java (99%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/SnapshotFile.java (94%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/StorageAction.java (95%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/ThrottledReplicaListValidator.java (97%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/TimeIndex.java (99%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/TimestampOffset.java (97%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/TransactionIndex.java (99%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/TxnIndexSearchResult.java (96%)
 rename storage/src/main/java/org/apache/kafka/{server/log/internals => storage/internals/log}/TxnMetadata.java (97%)