使用 xml 配置的 Spring 5.X web Kafka 集成（不是 Spring 启动）答案

【问题标题】：Spring 5.X web Kafka Integeration using xml configuration (Not Spring boot)使用 xml 配置的 Spring 5.X web Kafka 集成（不是 Spring 启动）
【发布时间】：2020-11-07 16:19:05
【问题描述】：

我正在尝试使用运行 Spring 5.2 发布项目（它不是 Spring Boot 项目）的 xml 配置在遗留 Web 应用程序上设置 kafka 使用者。查找后，我发现了一个使用 xml 配置设置 kafka 消费者的项目，如下所示

https://docs.spring.io/spring-kafka/docs/1.3.11.RELEASE/reference/html/_spring_integration.html

然而，这并没有详细说明如何在 Spring Web 应用程序中将其与 java 连接。所有示例均适用于 spring-boot 项目。我确实找到了需要添加到 xml 的配置

https://github.com/spring-projects/spring-integration-kafka

我也确实找到了 Spring Web 应用程序和 kafka 的示例，但它适用于 4.X 版本，并且是从 2015 年开始的。

https://techannotation.wordpress.com/2015/10/26/introduction-to-apache-kafka-using-spring/

对于任何更新的文档或如何在 2020 年使用 xml 配置在 java spring web 项目中设置使用者的任何帮助，我们将不胜感激

【问题讨论】：

标签： spring-integration spring-kafka

【解决方案1】：

不清楚你为什么一直提到 Spring Integration 框架，但你没有强调它。让我们看看这个文档是否对您有帮助：https://docs.spring.io/spring-integration/docs/current/reference/html/kafka.html#kafka！

注意 Spring Integration 已经是5.4了。

此示例基于 Spring Boot，但仍应让您大致了解如何使用 Java 配置 Kafka 通道适配器：https://github.com/spring-projects/spring-integration-samples/tree/master/basic/kafka

【讨论】：

我想我应该提到它是一个不使用 spring-boot 启动器的遗留 Spring Web 应用程序
没关系。您仍然可以使用 Spring Kafka 和 Spring Integration。只有您需要遵循最新版本说明的问题。我不确定你的 Spring 5.2 是什么意思，但如果你使用 Spring Integration，你真的应该接受 spring-integration-kafka 及其最新功能。
你在使用 Spring Integration 吗？如果没有，你只需要spring-kafka。 spring.io/projects/spring-kafka
我不认为我使用 spring 集成，因为直接使用 spring 框架依赖项。这是一项相当古老的服务，我正在尝试设置 kafka 消费者。它甚至不使用 java 配置，而是使用旧的 web xml 样式配置。
好的。所以，请遵循 Gary 建议的链接。

【解决方案2】：

在 Gary Russel 和 Artem Bilan 的帮助下，我能够解决这个问题。由于我使用的是旧版 spring 应用程序，因此我需要这个项目而不是 spring 集成项目

https://spring.io/projects/spring-kafka

我还按照此处的文档为 kafka 侦听器设置 java 配置

https://docs.spring.io/spring-kafka/docs/2.3.12.RELEASE/reference/html/#with-java-configuration

我用它来弄清楚如何让 java config 和 xml config 一起工作

https://memorynotfound.com/mixing-xml-java-config-spring/

这是我的实现的要点

https://gist.github.com/praveen2710/7dcf1671379ee6db4581436e1225c673

【讨论】：