Spring 5.X 使用 xml 配置的 Web Kafka 集成(不是 Spring 启动)

Spring 5.X web Kafka Integeration using xml configuration (Not Spring boot)

我正在尝试使用 xml 配置 运行 Spring 5.2 发布项目(它不是 spring 启动)在遗留 Web 应用程序上设置一个 kafka 消费者项目)。 查找后,我发现了一个使用 xml 配置设置 kafka 消费者的项目,如此处

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

然而,这并没有详细说明如何在 spring 网络应用程序中将其与 java 连接。所有示例均针对 spring-boot 项目。我确实找到了我需要添加到 xml

的配置

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

我也确实找到了 Spring 网络应用程序和 kafka 的示例,但它是针对 4.X 发布的,并且是从 2015 年开始的。

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

任何有关更新文档或如何在 java spring Web 项目中使用 xml 配置在 2020 年设置消费者的任何帮助将不胜感激

不明白为什么一直提Spring集成框架,但又不强调。 让我们看看这个文档是否对您有帮助:https://docs.spring.io/spring-integration/docs/current/reference/html/kafka.html#kafka !

注意 Spring 集成已经 5.4

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

在 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 配置和 xml 配置一起工作

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

这是我的实施要点

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