Kafka 可接收的消息最大默认多少字节，如何修改?

在 Kafka 中，默认情况下可接收的最大消息大小为 **1,000,000 字节**（即 1 MB）。如果需要调整这个大小，可以在 Kafka Broker 的配置文件中修改 `message.max.bytes` 参数。 ### 修改步骤： 1. **修改 Broker 的 `message.max.bytes` 参数**： - 在 Kafka Broker 的配置文件 `server.properties` 中找到并修改 `message.max.bytes` 参数，设置你需要的值。例如： ```plaintext message.max.bytes=5000000 ``` 这表示将最大消息大小设置为 5 MB。 2. **调整相关的消费端参数**： - 修改 `fetch.message.max.bytes` 参数：消费者（Consumer）能读取的最大消息的字节数默认也是 1 MB。如果你增大了 `message.max.bytes`，那么消费者端的 `fetch.message.max.bytes` 参数也应相应增大，确保消费者能够读取 Broker 中的消息。例如： ```plaintext fetch.message.max.bytes=5000000 ``` 这表示消费者能够读取最大 5 MB 的消息。 - **注意顺序关系**：`fetch.message.max.bytes` 的值应该大于或等于 Broker 端的 `message.max.bytes`，否则消费者无法消费过大的消息，会导致系统异常或挂起。 3. **可能还需要调整的参数**： - **`replica.fetch.max.bytes`**：此参数定义了 Follower 副本从 Leader 副本拉取消息时，允许的最大字节数。它应该至少等于或大于 `message.max.bytes`，以确保副本间同步正常。 - **`max.request.size`**：生产者端的 `max.request.size` 参数也可能需要调整，以允许生产者发送更大的消息。默认值也是 1 MB，调整时应与 Broker 的 `message.max.bytes` 保持一致。 ### 注意事项： - **协调所有相关参数**：在增大 Kafka 可接收的最大消息大小时，确保所有相关的参数值都已经协调一致，避免因参数不匹配而引发系统异常。 - **性能影响**：增大消息大小可能会影响 Kafka 的性能，特别是在高负载情况下，因为处理更大的消息会消耗更多的内存和带宽。 通过以上步骤，你可以安全地调整 Kafka 可接收的最大消息大小，同时确保系统的稳定性和正常运行。