项目使用 springboot + kafka,有一个消息的内容比较大,出现了下面的异常
The message is 1330537 bytes when serialized which is larger than the maximum request size you have configured with the max.request.size configuration.
但是找了半天,不知道这个到底怎么配置,追踪了下源码也没看明白。哪位大神指导下?
其他的配置在 application.properties 中配置如下,
spring.kafka.bootstrap-servers=****
spring.kafka.consumer.group-id=vprGroup
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.ByteArraySerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.ByteArraySerializer
想按照上面的格式这么配也不行
spring.kafka.producer.max-request-size=2097152