Spring Cloud Stream Kafka Rekord zu groß

Question

Ich habe eine Anwendung, die versucht, ziemlich große (> 4 mb) Nachrichten über Kafka über Spring Cloud Stream zu senden. Ich erhalte derzeit diesen Fehler:

org.apache.kafka.common.errors.RecordTooLargeException: Diese Meldung ist 4280852 Bytes beim Serialisieren, die größer ist als die maximale Größe der Anfrage, die Sie mit der Konfiguration von max.request.size konfiguriert haben

Gibt es eine Möglichkeit, "max.request.size" für einen Spring Cloud Stream-Produzenten festzulegen?

Answer 1

Dies ist ein bekanntes Problem und sollte behoben werden, sobald https://github.com/spring-cloud/spring-cloud-stream/pull/588 zusammengeführt wird.