我运行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主题仅保留连接器本身的配置。
暂无答案!
目前还没有任何答案,快来回答吧!