嘿，这个问题我太熟了！不少人刚接触Kafka都会碰到大消息发不出去的坑，我给你一步步拆解清楚怎么解决~

一、核心逻辑：三方配置要同步调整 #

Kafka的消息大小限制不是单改某一端就行的，**Broker（服务器）、生产者（你的发送端）、消费者（如果有消费需求）**这三方的配置必须匹配，不然某一端卡壳就会失败。你那770KB的byte[]发不出去，大概率是某一端的默认限制比这个值还小（或者刚好卡线）。

二、具体配置项&修改位置 #

1. Broker端（服务器侧） #

修改Kafka安装目录下的config/server.properties文件（集群部署的话所有Broker都要改，改完重启Broker生效）：

• message.max.bytes：Broker允许接收的单条消息最大字节数，默认是1048576（1MB）。你可以设成2097152（2MB），完全覆盖770KB的需求。
• replica.fetch.max.bytes：Broker之间同步副本时允许的最大消息字节数，这个值必须≥message.max.bytes，不然副本同步会失败，同样设成2097152就好。

2. 生产者端（你的发送代码/配置文件） #

不管你发的是String还是byte[]类型的消息，生产者侧必须对应调整：

• 如果是代码里配置：在创建ProducerConfig时添加max.request.size参数，值设为2097152（这个配置限制了生产者单次请求的最大字节数，单条消息不能超过它）；另外buffer.memory可以适当调大，比如33554432（32MB），避免大消息占满缓存。
• 如果是用独立配置文件（比如producer.properties）：直接在文件里加两行：

  max.request.size=2097152
  buffer.memory=33554432
  

  改完重启生产者客户端生效。

3. 消费者端（如果需要消费这条大消息） #

要是你之后要消费这条770KB的消息，消费者侧也得改配置，不然拉取会失败：

• fetch.max.bytes：消费者单次拉取的最大字节数，设为2097152；
• max.partition.fetch.bytes：从单个分区拉取的最大字节数，同样设为2097152。
  配置位置和生产者类似，代码里加参数或者修改consumer.properties都行。

三、关键注意点 #

• 所有配置的大小要保持合理关系：replica.fetch.max.bytes ≥ message.max.bytes，max.request.size ≥ 你的消息实际大小，消费者的两个配置也要≥message.max.bytes。
• 建议给配置留些余量，比如把最大限制设成消息大小的1.2倍左右，避免消息头、序列化额外字节等导致的超限。

内容的提问来源于stack exchange，提问作者neb