我读到了Apache Kafka,我偶然发现了它的消费者群体的概念。我不理解的是它的用例。来自不同组的两个不同的消费者可以阅读正在发布的相同消息。为什么要由两个不同的消费者处理相同的消息?有人能给出一个实际的用例吗?
发布于 2016-08-27 07:51:44
您希望将数据写入MySQL和Elastic Search,并且您有一个读取事件并将某些事件标记为“错误”的应用程序。
这些用例中的每一个都是一个单独的应用程序,它想要查看所有事件,因此它们将是单独的消费者组,每个用户组都将看到所有消息。
发布于 2016-08-27 20:46:23
这实际上是Kafka中最典型的场景:应用程序生成一条消息,您有两个不同的系统为该数据创建两个不同的视图(即在ES中对其进行索引,并在Redis中对其进行缓存)。
在Kafka之前,让你的应用程序将数据双重写入两个应用程序是很常见的,所有的问题都是双重写入带来的一致性。
使用Kafka,您可以以组的形式拆分出尽可能多的消费者系统,还具有并行性和容错性,在组中具有多个分区和消费者实例。
https://stackoverflow.com/questions/39173195
复制相似问题