暂停消息消费并在时间间隔后恢复

Question

我们正在使用 spring-cloud-stream 来处理 kafka。而且我需要在消费者从单个主题获取数据之间添加一些间隔。 batch-node 已设置为 true ， fetch-max-wait、fetch-min-size、max-poll-records 也已调整。

我应该用 idleEventInterval 做点什么，还是方法不对？

Answer 1

您可以根据需要暂停/恢复容器（避免重新平衡）。

见https://docs.spring.io/spring-cloud-stream/docs/3.2.1/reference/html/spring-cloud-stream.html#binding_visualization_control

从 3.1 版开始，我们公开了org.springframework.cloud.stream.binding.BindingsLifecycleController，它被注册为 bean，一旦注入就可以用来控制单个绑定的生命周期

如果你只想延迟一小段时间，你可以设置容器的idleBetweenPolls属性，使用ListenerContainerCustomizer bean。