This is an automated email from the ASF dual-hosted git repository.
showuon pushed a change to branch 3.9
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 6b039ce75b8 KAFKA-16390: add
`group.coordinator.rebalance.protocols=classic,consumer` to broker configs when
system tests need the new coordinator (#16715)
new 4e75c57bbb7 KAFKA-17245: Revert TopicRecord changes. (#16780)
new 66485b04c69 KAFKA-16480: ListOffsets change should have an associated
API/IBP version update (#16781)
new 38db4c46ffd KAFKA-17205: Allow topic config validation in controller
level in KRaft mode (#16693)
new b622121c0ac KAFKA-16855: remote log disable policy in KRaft (#16653)
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../kafka/clients/admin/KafkaAdminClient.java | 4 +
.../org/apache/kafka/clients/admin/OffsetSpec.java | 19 ++++
.../admin/internals/ListOffsetsHandler.java | 6 +-
.../clients/consumer/internals/OffsetFetcher.java | 2 +-
.../consumer/internals/OffsetsRequestManager.java | 2 +-
.../apache/kafka/common/config/TopicConfig.java | 19 ++--
.../kafka/common/requests/ListOffsetsRequest.java | 9 +-
.../kafka/clients/admin/KafkaAdminClientTest.java | 56 ++++++++++
.../common/requests/ListOffsetsRequestTest.java | 4 +-
.../kafka/common/requests/RequestResponseTest.java | 6 +-
.../java/kafka/log/remote/RemoteLogManager.java | 83 +++++++++-----
core/src/main/scala/kafka/log/LogManager.scala | 10 +-
.../main/scala/kafka/server/ConfigHandler.scala | 62 ++++++++---
.../server/ControllerConfigurationValidator.scala | 11 +-
.../main/scala/kafka/server/ReplicaManager.scala | 5 +-
core/src/main/scala/kafka/zk/AdminZkClient.scala | 9 +-
.../kafka/log/remote/RemoteLogManagerTest.java | 27 ++---
.../kafka/admin/RemoteTopicCrudTest.scala | 71 ++++++++++--
.../kafka/api/AuthorizerIntegrationTest.scala | 2 +-
.../kafka/api/BaseAdminIntegrationTest.scala | 2 +-
.../test/scala/unit/kafka/log/LogConfigTest.scala | 88 +++++++++++----
.../test/scala/unit/kafka/log/LogManagerTest.scala | 2 +-
.../kafka/log/remote/RemoteIndexCacheTest.scala | 8 +-
.../ControllerConfigurationValidatorTest.scala | 51 ++++++---
.../kafka/server/DynamicConfigChangeTest.scala | 13 ++-
.../scala/unit/kafka/server/KafkaApisTest.scala | 4 +-
.../unit/kafka/server/ListOffsetsRequestTest.scala | 24 +++--
.../scala/unit/kafka/server/LogOffsetTest.scala | 2 +-
.../scala/unit/kafka/server/RequestQuotaTest.scala | 2 +-
.../jmh/common/ListOffsetRequestBenchmark.java | 2 +-
.../controller/ConfigurationControlManager.java | 10 +-
.../kafka/controller/ConfigurationValidator.java | 9 +-
.../resources/common/metadata/TopicRecord.json | 10 +-
.../kafka/metadata/util/RecordRedactorTest.java | 2 +-
.../remote/storage/RemoteLogSegmentMetadata.java | 22 +---
.../storage/RemoteLogSegmentMetadataTest.java | 8 +-
.../RemoteLogSegmentMetadataTransform.java | 2 +-
.../kafka/storage/internals/log/LogConfig.java | 86 +++++++++++----
.../remote/metadata/storage/ConsumerTaskTest.java | 2 +-
.../storage/RemoteLogMetadataCacheTest.java | 4 +-
.../storage/RemoteLogMetadataFormatterTest.java | 2 +-
.../storage/RemoteLogMetadataSerdeTest.java | 2 +-
.../storage/RemoteLogMetadataTransformTest.java | 2 +-
.../storage/RemoteLogSegmentLifecycleTest.java | 6 +-
...ogMetadataManagerMultipleSubscriptionsTest.java | 4 +-
...icBasedRemoteLogMetadataManagerRestartTest.java | 6 +-
.../TopicBasedRemoteLogMetadataManagerTest.java | 20 ++--
.../RemoteLogSegmentMetadataTransformTest.java | 3 +-
.../log/remote/storage/LocalTieredStorageTest.java | 4 +-
.../storage/RemoteLogMetadataManagerTest.java | 4 +-
.../integration/DisableRemoteLogOnTopicTest.java | 120 +++++++++++++++++++++
51 files changed, 694 insertions(+), 239 deletions(-)
create mode 100644
storage/src/test/java/org/apache/kafka/tiered/storage/integration/DisableRemoteLogOnTopicTest.java
