我有4个服务A,B,C & D,在一个主题中发送相同的对象。然后,我有4个其他服务W,X,Y和Z,在同一个前一个主题中使用消息。我的问题是:
怎么做?什么都没做我所考虑的是组,但与groupes我们可以重新平衡,只是不指定每个消息女巫组可以阅读的消息。
cmssoen21#
这是不可能的; Kafka消费者总是会阅读关于某个主题的所有事件。即使在使用者代码中定义了条件过滤器,仍然需要从代理获取字节,对数据进行格式化,然后查看“谁发送了这条消息?“
1条答案
按热度按时间cmssoen21#
这是不可能的; Kafka消费者总是会阅读关于某个主题的所有事件。
即使在使用者代码中定义了条件过滤器,仍然需要从代理获取字节,对数据进行格式化,然后查看“谁发送了这条消息?“