我正在使用mongodb源连接器将mongodb集合中的数据获取到kafka中。此连接器的作用是使用以下命名约定自动创建主题：
[前缀\u在\u连接器\u属性中提供了\u]。[数据库\u名称]。[集合\u名称]
在mongodb源连接器的文档中，没有提到覆盖主题配置，例如分区数或复制因子。我有以下问题：
是否可以覆盖connector.properties文件中的主题configs？
如果没有，那是不是Kafka的结局？如果是这样的话，我们可以单独配置每个主题的设置，否则它会全局影响所有主题吗？
谢谢您！
1条答案
按热度按时间km0tfn4u1#
听起来你有
auto.create.topics.enable=true你的经纪人。建议禁用此功能并强制手动创建主题。connect只为自己创建内部主题。理想情况下，源连接器应该提前创建主题，否则，您将在代理中设置默认值
server.properties. 更改值不会更改现有主题