我是 kafka 的新手,我正在考虑将 kafka 消息队列与传入的 http 请求集成在我的 Web 应用程序中使用。 在这里,我的问题是如何将 Tomcat 中的传入请求捕获到我的 Kafka,以及我的 Spring MVC 应用程序应该以哪种格式使用。我不确定这是否是正确的方法。
您可以使用围绕 http 请求制作 rest API。
使 Domain 对象解析来自请求的传入数据并将其发送到 Kafka 集群以简化其他系统,这将需要实时数据,
SpringKafka 与 Spring MVC 一样具有魅力。
如需进一步参考,您可以查看以下链接:https://www.codenotfound.com/2016/09/spring-kafka-consumer-producer-example.html
希望它能帮助您的想法:)