设置connections.max.idle.ms不适用于使用Docker的Kafka Connect



我正在尝试设置connections.max.idle.ms属性,但它似乎不起作用。根据kafka文档,只需要添加前缀CONNECT_并用下划线替换句点。以下是我如何在docker compose文件中设置它:

environment:
CONNECT_CONNECTIONS_MAX_IDLE_MS: 10000
...

但是当我检查kafka-connect的日志时,属性保持不变:

[min]INFO org.apache.kafka.clients.admin.AdminClientConfig-AdminClientConfig值:bootstrap.servers=[kafka:29092]client.dns.lookup=默认client.id=connections.max.idle.ms=300000

我使用的是confluentinc/cp-kafka-connect:5.2.2docker镜像。

你能告诉我我在这里做错了什么吗?

谢谢。

CONNECT_变量仅传递到connect-distributed.properties

Connect不存在该属性,只有AdminClient不存在,因此,假设AdminClient属性可以按照生产者和消费者的方式进行配置(例如,consumer.override.max.poll.records,即CONNECT_CONSUMER_OVERRIDE_MAX_POLL_RECORDS(,则需要相应地调整变量。

此外,5分钟是一个很长的超时时间,因为它是。没有理由缩短它

最新更新