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

Question

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

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

confluent-5.5.0/etc/kafka/生产者属性

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/customer.properties

max.partition.fetch.bytes=15728640

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

max.request.size=15728640

注意：connect.log 中没有更新这些值

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

我是不是错过了什么？

以下我也尝试过评论中的信息：

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

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

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

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

仍处于最大.request.size尚未更改。

(已解决(基于输入：

我已在连接中添加了上述配置或配置。还将政策从"无"改为"全部"。它正确地应用了配置更改。

Answer 1

Connect不使用这些文件。

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

您需要使用connect-distributed.properties或connect-standalone.properties，并注意您还需要使用前缀正确设置属性。

Answer 2

解决方案是在kafka-connect-proprties文件中设置配置：在分布式或独立连接属性文件中添加以下内容

producer.max.request.size=157286400
consumer.max.request.size=157286400
max.request.size=157286400

它会起作用的！！！