假设我有一个微服务,它发出kafka事件,微服务处理程序将通过kafka侦听器处理它。处理程序微服务应该扩展,我相信我应该通过我的流中的kafka组id来扩展,但我不明白如果一个微服务已经开始处理一个kafka事件,其他处理程序将如何不处理发出的kafka事件。你能帮我理解一下吗?
niknxzdl1#
使用相同的消费群体,给他们提供相同的群体。这样的话,他们中只有一个人能够使用每条消息你可以在这里了解更多
1条答案
按热度按时间niknxzdl1#
使用相同的消费群体,给他们提供相同的群体。这样的话,他们中只有一个人能够使用每条消息
你可以在这里了解更多