Я ищу способ прекратить потребление сообщений с помощью потокового прослушивателя.
@StreamListener(MBinding.M_INPUT)
public void consumeMessage(Message<MerchantEvent> message) {
//handle when receive message
}
cloud:
stream:
bindings:
MInput:
destination: topicName
group: groupName
Я прогуглил это, но сейчас все еще не знаю, как прекратить потребление. Кто-нибудь знает это?