如何从应用程序外部停止Kafka Listener Bean? [英] How to stop the Kafka Listener beans from outside the application?

问题描述

如果服务器上运行的是Kafka Consumers，是否可以通过例如REST服务从应用程序外部选择性地停止侦听器bean?

If there are Kafka Consumers running on a server, is it possible to selectively stop the listener beans from outside the application, by a REST service for example??

推荐答案

假设您使用的是spring-kafka(已标记)，是的；请参阅文档.

Assuming you are using spring-kafka (which you tagged), yes; see the documentation.

您可以使用KafkaListenerEndpointRegistry启动和停止所有或单个侦听器.

You can start and stop all or individual listeners using the KafkaListenerEndpointRegistry.

这篇关于如何从应用程序外部停止Kafka Listener Bean?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！