KDATA-360: Add feature flag and cloud API for TTP snapshots (#7027)
This PR adds below feature flag - tier.topic.snapshots.enable - tier.topic.snapshots.interval.ms Also, defines the Cloud API for uploading TTP snapshots based on https://confluentinc.atlassian.net/wiki/spaces/KSTORAGE/pages/2549122180/Tier+Topic+Snapshots reviewer: @RamanVerma
显示
- clients/src/main/java/org/apache/kafka/common/config/internals/ConfluentConfigs.java 12 个添加, 0 个删除...pache/kafka/common/config/internals/ConfluentConfigs.java
- core/src/main/java/kafka/tier/store/TierObjectStore.java 98 个添加, 6 个删除core/src/main/java/kafka/tier/store/TierObjectStore.java
- core/src/main/scala/kafka/server/KafkaConfig.scala 19 个添加, 1 个删除core/src/main/scala/kafka/server/KafkaConfig.scala
- core/src/test/scala/kafka/tier/store/TierTopicSnapshotTest.scala 28 个添加, 0 个删除...c/test/scala/kafka/tier/store/TierTopicSnapshotTest.scala
- core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala 15 个添加, 0 个删除core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala
加载中
想要评论请 注册 或 登录