java - 在哪里设置 Apache Kafka 中的最大消息大小？

Question

我可以在哪个文件中增加 Kafka 的最大消息大小？ (我正在发送 String，byte[] 的记录，当我发送 770kb 的 byte[] 时，Kafka 没有发送消息)

Answer 1

在kafka 0.11.0中需要设置以下四个配置选项

经纪人配置选项(details):

1. message.max.bytes - Kafka 允许的最大记录批大小。

2. replica.fetch.max.bytes - 尝试为每个分区获取的消息的字节数。

生产者配置选项(details):

1. max.request.size - 请求的最大大小(以字节为单位)。建议将该值与 (message.max.bytes) 匹配。

消费者配置选项(details):

1. max.partition.fetch.bytes - 服务器返回的每个分区的最大字节数。应该大于 max.message.size 以便消费者可以读取代理发送的最大消息。