我在kafka建立一个topic,然后诉求如下:
1.客户通过账户登录到系统。
2.kafka在同一个topic下,将属于这个账号的信息推送给这个账户。
比如后端可以通过SQL的where条件,将属于这个账户下的信息经过kafka推送给这个客户。
我在kafka建立一个topic,然后诉求如下:
1.客户通过账户登录到系统。
2.kafka在同一个topic下,将属于这个账号的信息推送给这个账户。
比如后端可以通过SQL的where条件,将属于这个账户下的信息经过kafka推送给这个客户。
假设您用了阿里云这类付费中间件,出于节省成本的考虑,仅在拥有一个 topic 的情况下:
按照您的 “客户通过账户登录到系统” 这一描述,客户应该也只是登录 Web 系统,kafka consumer 应该也还是个后端服务,那么您可以在这个 consumer 这里建立消息的二次分发流程,通过自定义 event 的数据来自己在 consumer 内部实现用户的精确推送。
也就是说,可以将 topic 本身当作是一个大类,而大类下属还可以有自己的二级分类,但这个二级分类只能是自己去定义规则并且实现。