基于kafka的通知引擎发送推送通知从android应用程序中的不同用户获得id

Question

我正在设计一个通知引擎(基于打字本)，它将作为一个一站式商店，为各种其他系统发送通知到不同的渠道(推送通知，短信，电子邮件等)。我希望构建这个系统来使用Kafka作为message组件(还有许多其他组件)。

我的查询是针对app推送通知的(我们当前的系统使用基于FCM主题的订阅通知，来自发布的各个系统)。Notification将以Kafka生产者的身份工作，并定期向主题发布消息(如此系统的Scheduler组件中所配置的)。应用程序用户如何在通知发布后立即获得通知？我假设这里的应用程序必须像卡夫卡消费者那样工作。实现这一目标的最佳途径是什么？卡夫卡REST代理是移动应用程序充当卡夫卡消费者的选择吗？移动应用程序是否会超载来承担所有的消费者责任？

Answer 1

我不想让这款手机应用成为消费者，原因有两个

side

• scaleability -您将需要在客户端

• 上保存creds -每个移动设备都充当使用者，这将使主题的吞吐量随着

用户数的增加而增加。

我建议您编写一个新组件，它使用kafka的消息并通过套接字数据发布给移动客户端。

看看socket.io，支持类型记录，也是一个易于使用的库。

祝好运!