美文网首页
第5章 5.2 消费者之间如何交互

第5章 5.2 消费者之间如何交互

作者: loinue | 来源:发表于2022-06-07 16:07 被阅读0次

    为什么消费者组的概念很重要?可能最主要的原因是,从一个组中添加或删除消费者都会影响消费规模。不属于同一组的消费者不共享相同的offset协调处理。下列显示了一个名为kinaction_team0group组的示例。如果您又起一个新的组group.id(如随机GUID),您将启动一个新的消费者,没有存储偏移量,组中也没有其他消费者。如果您加入了一个现有的组(或者一个已经存储了偏移量的组),您的消费者可以与其他人共享offset,甚至可以从以前运行后停止的offset恢复读取。

    '''
    Properties kaProperties = new Properties();
    kaProperties.put("group.id", "kinaction_team0group");
    '''

    通常情况下,你会有很多消费者订阅同一主题。要决定是否需要一个新的组ID的一个重要细节是,您的消费者是作为一个应用程序的一部分工作,还是作为一个单独的逻辑流工作。为什么这很重要?
    让我们考虑一下来自人力资源系统数据的两个用例。
    一个团队想知道来自特定州的招聘数量,
    而另一个团队对面试数据对旅行预算的影响更感兴趣。
    一线队中是否有人关心其他团队在做什么,或者有没有哪个团队愿意只消费一部分信息?可能不会!我们怎样才能保持这种分离呢?
    答案是为每个应用程序分配一个单独的组id。使用相同组id的每个消费者将被认为是在一起工作,将主题的分区和偏移量作为一个逻辑应用程序来使用。

    总结:没有新的知识,就是类似数据的复制作用。

    相关文章

      网友评论

          本文标题:第5章 5.2 消费者之间如何交互

          本文链接:https://www.haomeiwen.com/subject/hwsemrtx.html