首页 > 解决方案 > 没有其他 @StreamListener(condition) 不匹配时的默认流侦听器

问题描述

我在给定主题上有多种事件类型,但我只对这些事件类型的子集感兴趣。我有一个消费者组,但每个事件类型有多个 @StreamListener。但这会导致抵消滞后,因为我不感兴趣的事件并不代表我的消费者群体的实际滞后。这是因为我将自动提交设置为 false。因此,作为一种解决方案,我正在考虑使用一个默认的流侦听器,当没有过滤器匹配时,该侦听器会在最后选择,并且该侦听器只会手动提交偏移量。这样,我对消费者群体的滞后将反映实际值。有人可以建议我如何使用 SCSt 做到这一点吗?

标签: spring-cloud-stream

解决方案


推荐阅读