spring 包含 maxRequestSize 的云流 kafka 活页夹版本是什么
what is the spring cloud stream kafka binder version that includes maxRequestSize
我 运行 在向 kafka 主题发布事件时出现以下异常
org.apache.kafka.common.errors.RecordTooLargeException: The message is 2063239 bytes when serialized which is larger than the maximum request size you have configured with the max.request.size configuration.
我看了https://github.com/spring-cloud/spring-cloud-stream/issues/587
我正在使用以下 spring 云版本,并且没有在我的 pom
中向 spring-cloud-stream-kafka-binder
提供任何版本
<spring-cloud-stream.version>Brooklyn.SR3</spring-cloud-stream.version>
<spring-cloud.version>Brixton.SR7</spring-cloud.version>
我应该使用什么 spring-cloud-stream 版本的 jar 才能使用这个 属性?
使用 Brooklyn (binder 1.1.2),使用通用 configuration
属性 地图...
spring.cloud.stream.kafka.binder.configuration.max.request.size=
全局设置或
spring.cloud.stream.kafka.bindings.<dest>.producer.configuration.max.request.size=
特定目的地(例如 output
)。
我 运行 在向 kafka 主题发布事件时出现以下异常
org.apache.kafka.common.errors.RecordTooLargeException: The message is 2063239 bytes when serialized which is larger than the maximum request size you have configured with the max.request.size configuration.
我看了https://github.com/spring-cloud/spring-cloud-stream/issues/587
我正在使用以下 spring 云版本,并且没有在我的 pom
中向spring-cloud-stream-kafka-binder
提供任何版本
<spring-cloud-stream.version>Brooklyn.SR3</spring-cloud-stream.version>
<spring-cloud.version>Brixton.SR7</spring-cloud.version>
我应该使用什么 spring-cloud-stream 版本的 jar 才能使用这个 属性?
使用 Brooklyn (binder 1.1.2),使用通用 configuration
属性 地图...
spring.cloud.stream.kafka.binder.configuration.max.request.size=
全局设置或
spring.cloud.stream.kafka.bindings.<dest>.producer.configuration.max.request.size=
特定目的地(例如 output
)。