我在试着 connections.max.idle.ms 财产，但似乎不起作用。根据Kafka的文档，只需要添加一个前缀 CONNECT_ 用下划线替换句点。下面是我如何在docker compose文件中设置它：
environment:
CONNECT_CONNECTIONS_MAX_IDLE_MS: 10000
...但当我检查Kafka连接的日志时，属性保持不变：
[main] INFO org.apache.kafka.clients.admin.AdminClientConfig - AdminClientConfig values:
bootstrap.servers = [kafka:29092]
client.dns.lookup = default
client.id =
connections.max.idle.ms = 300000
...我在用 confluentinc/cp-kafka-connect:5.2.2 docker图像。
你能告诉我我做错了什么吗？
谢谢您。
1条答案
按热度按时间2ledvvac1#
CONNECT_变量只传递到connect-distributed.properties对于connect，该属性不存在，只有adminclient，因此，假设adminclient属性可以按照生产者和消费者的方式进行配置（例如，consumer.override.max.poll.records，也就是CONNECT_CONSUMER_OVERRIDE_MAX_POLL_RECORDS)，则需要相应地调整变量。另外，5分钟是一个很长的超时时间，因为它是。没有理由缩短它