朋友们，我目前正在做一个项目，我需要使用Apache Kafka和Sping Boot 实现实时数据流。我一直在努力寻找关于如何正确设置这种集成的清晰文档或教程。以下是我到目前为止所尝试的：
1.我已经建立了一个Sping Boot 项目，并包含了Kafka集成所需的依赖项。
1.我已经在application.properties文件中配置了所需的Kafka属性。
1.我已经分别使用KafkaTemplate和KafkaListener注解创建了Kafka生产者和消费者类。
然而，尽管我努力，我无法让实时数据流顺利工作。我没有收到消费者方面的任何数据，我怀疑我可能错过了一些重要的配置步骤。
1条答案
按热度按时间mcvgt66p1#
在我看来，对于实时处理，Firebase（https://firebase.google.com/docs/database）更受欢迎，如果您想要一些定制，则可以使用WebSocket（https://spring.io/guides/gs/messaging-stomp-websocket/
在前端，构建了Web Socket客户端，用于接收来自服务器的任何消息。
老实说，消息代理实际上并不适合实时处理。因为它在发布/订阅时间期间具有延迟并且不能与前端交互。