我正在使用 Spring Cloud 来使用 Kafka 主题，进行一些处理并将结果存储在 Mongo DB 中。我注意到，如果我的消费者处理速度很慢，那么内存消耗会迅速攀升，直到服务停止。
进一步分析表明，Spring Cloud 默认使用 BUFFER 背压策略，因此缓冲区会填满并吃掉所有内存。
我的问题是，Spring 云中有没有办法指定背压策略（而不仅仅是缓冲）？如果没有，有没有办法限制/配置缓冲区大小？
我正在使用 Spring Cloud 来使用 Kafka 主题，进行一些处理并将结果存储在 Mongo DB 中。我注意到，如果我的消费者处理速度很慢，那么内存消耗会迅速攀升，直到服务停止。
进一步分析表明，Spring Cloud 默认使用 BUFFER 背压策略，因此缓冲区会填满并吃掉所有内存。
我的问题是，Spring 云中有没有办法指定背压策略（而不仅仅是缓冲）？如果没有，有没有办法限制/配置缓冲区大小？