当您在 kafka 上订阅事件时，我可以向订阅添加参数吗
When you subscribe to event on kafka can I add argument to the subscription
我的系统连接到外部 "microservice A"。（假设是 return 天气灾害预报）
"microservice A" 对我的系统和用户一无所知。
如果我有一个用户订阅了这项服务，
- 是否可以使用 "userid" 等参数订阅消息代理，所以当它 return 回答时，我将能够知道该用户已订阅并将回答发送给他。
1.1。如果答案是肯定的，这是最好的做法吗，因为现在我将有数百万订阅者使用 userid 而不是一个订阅，然后拉出所有已订阅的用户并将其发送给他们通知
这里最好的选择是什么？
除了主题的分区之外，您可以做的查询没有进一步的预测。换句话说，在不实际检查每条记录的情况下扫描主题时，不可能进行 ID 查找。
但是，您可以使用流处理引擎将某些用户 ID 过滤到不同的主题中供下游进程使用，或者您可以构建一个 table 所有事件，按 userId 分组。
I will be able to know this user have been subscribe and send him the answer
在 Kafka API 中，消费者自己请求数据，他们不是 "sent" 任何东西
我的系统连接到外部 "microservice A"。（假设是 return 天气灾害预报） "microservice A" 对我的系统和用户一无所知。 如果我有一个用户订阅了这项服务，
- 是否可以使用 "userid" 等参数订阅消息代理，所以当它 return 回答时，我将能够知道该用户已订阅并将回答发送给他。
1.1。如果答案是肯定的，这是最好的做法吗，因为现在我将有数百万订阅者使用 userid 而不是一个订阅，然后拉出所有已订阅的用户并将其发送给他们通知
这里最好的选择是什么？
除了主题的分区之外，您可以做的查询没有进一步的预测。换句话说，在不实际检查每条记录的情况下扫描主题时，不可能进行 ID 查找。
但是，您可以使用流处理引擎将某些用户 ID 过滤到不同的主题中供下游进程使用，或者您可以构建一个 table 所有事件，按 userId 分组。
I will be able to know this user have been subscribe and send him the answer
在 Kafka API 中，消费者自己请求数据，他们不是 "sent" 任何东西