如何在Spring mvc中使用Apache kafka？可能吗？

Question

我是apache kafka的初学者,并试图学习融合 - kafka - rest - utils,但是我很困惑,我怎么能用它.

在搜索过程中,我发现了这个文档https://spring.io/blog/2015/04/15/using-apache-kafka-for-integration-and-data-processing-pipelines-with-spring

这是非常好的文档,但它并没有帮助我学习rest-utils.

融合kafka rest utils的git代码是

https://github.com/confluentinc/kafka-rest演示了如何使用rest kafka.但我想知道确切的程序,以便更加了解它.用一些简单的解释.任何人都可以建议我与我如何使用休息客户端的一些链接.请指导我这个.

这可能是一个愚蠢的问题,但我没有其他选择可以学习.

提前致谢.

Answer 1

首先尝试使用 spring MVC 创建 REST 服务，将 kafka 的东西放在一边。

一旦您能够运行“hello world”类型的 REST 服务，就可以选择 Kafka Docs。

请参阅有关如何创建 kafka 集群的文档，并运行默认控制台消费者和生产者程序来检查您的集群。

现在，编写一个主 java 程序并使用Kafka Clients API创建一个 kafka 生产者。请参阅其文档。确保通过主程序发送的消息到达消费者。

现在，将此主程序的内容注入到rest服务中，以便请求正文中传递的消息现在传递到kafka集群并可供消费者读取。

希望能帮助到你。