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

Question

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

以下是我已经用 noluck 尝试过的参数:

confluence-5.5.0/etc/kafka/Producer.properties

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

confluence-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/confluence-5.5.0/etc/kafka/consumer.properties

  max.partition.fetch.bytes=15728640

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

  max.request.size=15728640

注意:这些值都不会在 connect.log 中更新

1. 我已经停止/启动了 confluence-5.5.0 ，甚至销毁了之前的镜像并重新启动。

我错过了什么吗？

根据评论中的信息，我也尝试了以下操作:

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

生产者.override.max.request.size=15728640Consumer.override.max.partition.fetch.bytes=15728640

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

生产者.override.max.request.size=15728640Consumer.override.max.partition.fetch.bytes=15728640

仍然是max.request.size没有改变。

(已解决)基于输入:

我在connect中添加了上面的配置或配置。并将政策从无更改为全部。正确应用了配置更改。

Answer 1

Connect 不使用这些文件。

• 服务器仅适用于 Apache Kafka Broker
• consumer| Producer 用于 kafka-console 实用程序
• kafka-rest 仅适用于 Confluence REST 代理

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