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 合并后立即修复。