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

Nav*_*pal 2 apache-kafka kafka-producer-api apache-kafka-connect

在 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
Run Code Online (Sandbox Code Playgroud)

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
Run Code Online (Sandbox Code Playgroud)

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

  max.partition.fetch.bytes=15728640
Run Code Online (Sandbox Code Playgroud)

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

  max.request.size=15728640
Run Code Online (Sandbox Code Playgroud)

注意:这些值都没有在 connect.log 中更新

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

我错过了什么吗?

在评论信息后我也尝试了以下内容:

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

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

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

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

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

(已解决)基于输入:

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

cri*_*007 5

Connect 不使用这些文件。

  • server仅适用于 Apache Kafka Broker
  • consumer|producer用于kafka-console公用事业
  • kafka-rest仅适用于 Confluence REST 代理

您需要使用connect-distributed.propertiesorconnect-standalone.properties并注意您需要另外使用前缀正确设置属性。

  • 如果放在“commect-distributed.properties”中,这里的设置对我有用:“ Producer.max.request.size = 15728640” (3认同)