当我使用@kafkalistener注解时，如何暂停kafka消费者

hl0ma9xz 于 2021-06-08 发布在 Kafka

关注(0)|答案(1)|浏览(754)

我正在从数据库中提取数据，以检查是否有可用的系统资源来处理来自kafkalistener的进一步消息。如果我的条件不满足，那么我希望@kafkalistener暂停，当条件满足时，我希望@kafkalistener继续。我如何在 Spring Kafka实现这一点？
暂停特定分区的使用者是否也有任何缺点？

apache-kafka kafka-consumer-api spring-kafka

来源：https://stackoverflow.com/questions/45307944/how-to-pause-kafka-consumer-when-i-am-using-kafkalistener-annotation

1条答案

按热度按时间

d6kp6zgx1#

根本没有 pause/resume 控件。只有在框架检测到慢速侦听器时才自动执行。
最新的 2.0 我们有相反的情况：我们不提供自动 pause/resume -没有理由了，但同时允许配置 @KafkaListener 方法与 Consumer 参数，这样您就可以在那里执行任何所需的逻辑了。

赞(0）回复(0）举报 2021-06-08

我来回答

当我使用@kafkalistener注解时，如何暂停kafka消费者

1条答案

相关问题

热门标签

最新问答