我正在寻找一种方法来停止使用流侦听器消费消息。
@StreamListener(MBinding.M_INPUT)
public void consumeMessage(Message<MerchantEvent> message) {
//handle when receive message
}
Run Code Online (Sandbox Code Playgroud)
cloud:
stream:
bindings:
MInput:
destination: topicName
group: groupName
Run Code Online (Sandbox Code Playgroud)
我用谷歌搜索过,但现在仍然不知道如何停止消费。有知道的人吗?