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

标签 docker apache-kafka apache-kafka-connect

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

environment:
      CONNECT_CONNECTIONS_MAX_IDLE_MS: 10000
...
但是当我检查kafka connect的日志时,该属性保持不变:
[main] 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属性可以通过they are for producers and consumers方式(例如consumer.override.max.poll.records,将是CONNECT_CONSUMER_OVERRIDE_MAX_POLL_RECORDS)进行配置,那么您需要相应地调整变量。
同样,5分钟实际上是很长的超时时间。没有理由缩短它

关于docker - 设置connections.max.idle.ms不适用于使用Docker的Kafka Connect,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/62924537/

相关文章:

java - Apache Kafka - 关于主题/分区的 KafkaStream

docker - 从 Windows 连接到 WSL 内的 docker 容器服务

mysql - 一个 Mysql 数据库的多个 debezium 连接器

maven - 从maven部署到nexus时指定版本

docker - 将代码放入 docker 容器的最佳实践是什么?

ruby-on-rails - Docker - docker-compose 'version' 没有任何配置选项

c# - 连接被拒绝 - Redis 在 ASP.Net Core 2.1 中用于数据保护 key

Docker 基础镜像文件系统

apache-kafka - 卡夫卡流: Exactly-once semantics for messages generated in a punctuator function

apache-kafka - Kafdrop (localhost/127.0.0.1 :9092) could not be established. 代理可能不可用