无法更改kafka connect中的配置设置,因为distributedconfig覆盖了该设置

2vuwiymt  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(281)

我运行Kafka连接在一个单一的吊舱运行kubernetes在分布式模式从strimzi/kafka:0.17.0-kafka-2.4.0 image (连接由strimzi操作员管理)
我想将“offset.flush.timeout.ms”的值从原来的设置5000改为30000,当我查看kafka connect的启动日志时,“提供的配置”部分设置了我的值:


# Provided configuration

value.converter=io.confluent.connect.avro.AvroConverter
offset.flush.timeout=30000
offset.storage.replication.factor=2

…但稍后在文件中,会出现有关“distributedconfig”的消息,这些消息会将值更改回我最初的默认值:

offset.flush.timeout.ms = 5000

这个分布式配置来自哪里?存在由connect使用的持久卷,connect config主题仅保留连接器本身的配置。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题