java - Spring Cloud Stream Kafka 记录太大

Question

我有一个应用程序试图通过 Spring Cloud Stream 在 Kafka 上发送相当大的（> 4 mb）消息。我目前收到此错误：

org.apache.kafka.common.errors.RecordTooLargeException：此消息在序列化时为 4280852 字节，大于您使用 max.request.size 配置配置的最大请求大小

有没有办法为 Spring Cloud Stream 生产者设置“max.request.size”？

Answer 1

这是一个已知问题，应在合并https://github.com/spring-cloud/spring-cloud-stream/pull/588后立即修复。