小编Ron*_*ani的帖子

我需要根据某些数据库驱动的属性打开/关闭 Kafka 消费者。怎样才能实现呢。

我想到的一种方法是：当消费者标志关闭时，从消费者抛出异常。容器工厂配置定义为

factory.setErrorHandler(new SeekToCurrentErrorHandler());

但它积极寻求同样的信息。

有什么办法可以根据需要关闭心跳然后再打开。