我正在设计一个通知引擎（基于 Java），它将用作各种其他系统的一站式商店，以将通知发送到不同的渠道（推送通知、SMS、电子邮件等）。我希望构建这个系统以使用 Kafka 作为消息代理组件（还有许多其他组件）。
我的查询特定于应用程序推送通知（我们当前的系统使用来自发布的各个系统的基于 FCM 主题的订阅通知）。新的通知引擎将作为 Kafka 生产者工作，并定期向主题发布消息（如本系统的调度程序组件中配置的那样）。应用程序用户如何在通知发布后立即获得通知？我假设这里的应用程序必须作为 Kafka Consumer 工作。实现这一目标的最佳方法是什么？Kafka REST 代理是否可以让移动应用程序像 Kafka 消费者一样行动？移动应用程序承担所有消费者责任会不会超负荷？