java - 当您订阅 kafka 上的事件时，我可以向订阅添加参数吗

Question

我的系统连接到外部“微服务A”。(假设它返回天气灾害预报)“微服务A”对我的系统和用户一无所知。如果我有一个已订阅此服务的用户，

1. 是否可以使用“userid”等参数订阅消息代理，以便当它返回答案时我将能够知道该用户已订阅并向他发送答案。

1.1。如果答案是肯定的，那么这是最佳实践，因为现在我将拥有数百万具有用户 ID 的订阅者，而不是一个订阅，然后提取所有已订阅的用户并向他们发送通知

这里最好的选择是什么？

Answer 1

除了主题分区之外，您无法进行进一步的查询投影。换句话说，在扫描主题而不实际检查每条记录时，不可能进行 ID 查找。

但是，您可以使用流处理引擎将某些用户 ID 过滤到不同的主题中以供下游进程使用，或者您可以构建所有事件的表，按 userId 分组。

I will be able to know this user have been subscribe and send him the answer

在 Kafka API 中，消费者自己请求数据，他们不会被“发送”任何东西