我正在尝试设置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.2
docker镜像。
你能告诉我我在这里做错了什么吗?
谢谢。
CONNECT_
变量仅传递到connect-distributed.properties
Connect不存在该属性,只有AdminClient不存在,因此,假设AdminClient属性可以按照生产者和消费者的方式进行配置(例如,consumer.override.max.poll.records
,即CONNECT_CONSUMER_OVERRIDE_MAX_POLL_RECORDS
(,则需要相应地调整变量。
此外,5分钟是一个很长的超时时间,因为它是。没有理由缩短它