我正在设计一个通知引擎（基于java），它将被用作各种其他系统的一站式服务，用于向不同的渠道（推送通知、短信、电子邮件等）发送通知。我希望构建这个系统以使用kafka作为消息代理组件（还有许多其他组件）。
我的查询特定于应用程序推送通知（我们当前的系统使用来自发布的各个系统的基于fcm主题的订阅通知）。新的通知引擎将作为Kafka生产者工作，并定期向主题发布消息（在该系统的调度程序组件中配置）。应用程序用户如何在通知发布后立即获得通知？我假设这里的应用程序必须作为Kafka的消费者。实现这一目标的最佳方法是什么？Kafkarest代理是移动应用程序像Kafka消费者一样的一种选择吗？移动应用处理所有消费者的责任会不会超载？