Kafka Connect 5.5.0 - 无法重置 max.request.size

Kafka Connect 5.5.0 - Unable to reset max.request.size

在 confluent-5.5.0 中 - 我无法更改 max.request.size ，它在 ProducerConfig 中始终默认为 max.request.size = 1048576。

以下是我用noluck试过的参数：

confluent-5.5.0/etc/kafka/producer.properties

  max.request.size=15728640
  producer.max.request.size=15728640

confluent-5.5.0/etc/kafka/server.properties

  message.max.bytes=15728640
  replica.fetch.max.bytes=15728640
  max.request.size=15728640
  fetch.message.max.bytes=15728640

/data/confluent-5.5.0/etc/kafka/consumer.properties

  max.partition.fetch.bytes=15728640

confluent-5.5.0/etc/kafka-rest/kafka-rest.properties

  max.request.size=15728640

注意：这些值中的 None 正在 connect.log

中更新
  1. 我有stop/started confluent-5.5.0 ，连之前的镜像都毁了重启

我是不是漏掉了什么？

根据评论中的信息我也尝试了以下内容：

/data/confluent-5.5.0/etc/kafka/connect-standalone.properties

producer.override.max.request.size=15728640 consumer.override.max.partition.fetch.bytes=15728640

/data/confluent-5.5.0/etc/kafka/connect-distributed.properties

producer.override.max.request.size=15728640 consumer.override.max.partition.fetch.bytes=15728640

还在max.request.size还没变。

（已解决）基于输入：

我在connect里添加了上面的配置 或配置。并且还将策略从 none 更改为 ALL。正确应用了配置更改。

Connect 不使用这些文件。

  • server 仅适用于 Apache Kafka Broker
  • consumer|producer 用于 kafka-console 实用程序
  • kafka-rest 仅适用于 Confluent REST 代理

您需要使用 connect-distributed.properties 或 connect-standalone.properties 并注意您需要 additionally set the property correctly 使用前缀。