我将尝试通过描述它解决的问题来解释它。
因此,假设您有一个要使用的消息主题,因此您编写了一个使用者。每次您使用一条消息时,偏移量都会更新,以便您的应用程序知道它已被使用并且可以使用下一条消息。
您意识到您的使用者应用程序无法处理所有传入的消息,因此您需要扩展它。您的应用程序的这两个实例不想使用另一个实例已使用的消息,因此它们有点想共享偏移量,因此它们需要位于同一个使用者组中。
如果您正在编写一个全新的应用程序,该应用程序也使用同一主题但需要独立执行此操作,则它需要位于自己的消费者组中,以便拥有自己的偏移量
| 归档时间: |
|
| 查看次数: |
492 次 |
| 最近记录: |