我在试着 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分钟是一个很长的超时时间,因为它是。没有理由缩短它