是否可以根据在一段时间内随机出现的标准对消息进行分组？消息具有不同的标识符，并且标识符可能需要存储在存储器中以进行关联。
3zwjbxry1#
我想Kafka不是关于分组信息。很可能您可以创建一个消费者，它检测正常消息流中的组，并将找到的组作为ID列表发布到不同的主题下。然后，该主题的使用者可以检索分组消息。
1条答案
按热度按时间3zwjbxry1#
我想Kafka不是关于分组信息。很可能您可以创建一个消费者，它检测正常消息流中的组，并将找到的组作为ID列表发布到不同的主题下。
然后，该主题的使用者可以检索分组消息。