debezium/dbz

Allow passing topic creation settings in Kafka sink

Open

#1,666 创建于 2026年3月4日

在 GitHub 查看
 (5 评论) (0 反应) (1 负责人)HTML (6 fork)auto 404
component/debezium-servergood first issuetype/enhancement

仓库指标

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?

贡献者指南