什么是kafka中的消费者组?

Raj*_*ala 0 apache-kafka

什么是kafka中的消费者组?请用一个用例来解释。

Ric*_*cho 5

我将尝试通过描述它解决的问题来解释它。

因此,假设您有一个要使用的消息主题,因此您编写了一个使用者。每次您使用一条消息时,偏移量都会更新,以便您的应用程序知道它已被使用并且可以使用下一条消息。
您意识到您的使用者应用程序无法处理所有传入的消息,因此您需要扩展它。您的应用程序的这两个实例不想使用另一个实例已使用的消息,因此它们有点想共享偏移量,因此它们需要位于同一个使用者组中。

如果您正在编写一个全新的应用程序,该应用程序也使用同一主题但需要独立执行此操作,则它需要位于自己的消费者组中,以便拥有自己的偏移量