myepoch 2021-09-02 16:42 采纳率: 0%
浏览 8

kafka在同一主题下能实现根据不同账号,推送不同消息吗?

我在kafka建立一个topic,然后诉求如下:

1.客户通过账户登录到系统。

2.kafka在同一个topic下,将属于这个账号的信息推送给这个账户。

  比如后端可以通过SQL的where条件,将属于这个账户下的信息经过kafka推送给这个客户。

  • 写回答

1条回答 默认 最新

  • 写代码的小吴 2022-09-21 19:27
    关注

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

    评论

报告相同问题?

问题事件

  • 创建了问题 9月2日

悬赏问题

  • ¥15 基于卷积神经网络的声纹识别
  • ¥15 Python中的request,如何使用ssr节点,通过代理requests网页。本人在泰国,需要用大陆ip才能玩网页游戏,合法合规。
  • ¥100 为什么这个恒流源电路不能恒流?
  • ¥15 有偿求跨组件数据流路径图
  • ¥15 写一个方法checkPerson,入参实体类Person,出参布尔值
  • ¥15 我想咨询一下路面纹理三维点云数据处理的一些问题,上传的坐标文件里是怎么对无序点进行编号的,以及xy坐标在处理的时候是进行整体模型分片处理的吗
  • ¥15 CSAPPattacklab
  • ¥15 一直显示正在等待HID—ISP
  • ¥15 Python turtle 画图
  • ¥15 stm32开发clion时遇到的编译问题