仓库指标
- Star
- (3 star)
- PR 合并指标
- (PR 指标待抓取)
描述
Feature request or enhancement
For feature requests or enhancements, please provide the following information:
Which use case/requirement will be addressed by the proposed feature?
In Kafka Connect, users can pass settings to the runtime, such as topic.creation.*, to define default replication factor, partitions, cleanup policy, and compression for topics; however, this is not currently possible when using the Debezium Server Kafka sink.
For parity sake, we should consider introducing the AdminClient to the Kafka sink, where we could create the topic with the desired creation settings before publishing, bringing the same level of topic creation control to Debezium Server that Kafka Connect offers.
Implementation ideas (optional)
#community-operator > ✔ How to specify the topic default cleanup policy?