如何在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

这是非常好的文件，但它并不能帮助我学会休息-utils的。

的融合卡夫卡的git的代码休息utils的是

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

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

在此先感谢。

Answer 1

首先尝试create a REST service using spring MVC保留kafka的东西放在一边。

一旦您能够运行'hello world'类的REST服务，然后选择Kafka Docs。

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

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

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

希望它有帮助。