From: Kai Moritz <kai@juplo.de> Date: Sat, 25 Jun 2022 13:08:12 +0000 (+0200) Subject: WIP X-Git-Tag: bytestream-producer~1 X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=635da7176b0c9f87e05bbdc433764e8b8ee6c8d3;p=demos%2Fkafka%2Ftraining WIP --- diff --git a/pom.xml b/pom.xml index ba3b8366..0d0ad53a 100644 --- a/pom.xml +++ b/pom.xml @@ -36,8 +36,12 @@ <artifactId>spring-boot-starter-integration</artifactId> </dependency> <dependency> - <groupId>org.springframework.kafka</groupId> - <artifactId>spring-kafka</artifactId> + <groupId>org.springframework.integration</groupId> + <artifactId>spring-integration-stream</artifactId> + </dependency> + <dependency> + <groupId>org.springframework.integration</groupId> + <artifactId>spring-integration-kafka</artifactId> </dependency> <dependency> <groupId>org.projectlombok</groupId> diff --git a/src/main/resources/integration.xml b/src/main/resources/integration.xml new file mode 100644 index 00000000..2b22bcde --- /dev/null +++ b/src/main/resources/integration.xml @@ -0,0 +1,12 @@ +<?xml version="1.0" encoding="UTF-8"?> +<beans:beans xmlns:int-stream="http://www.springframework.org/schema/integration/stream" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xmlns:beans="http://www.springframework.org/schema/beans" + xsi:schemaLocation="http://www.springframework.org/schema/beans + https://www.springframework.org/schema/beans/spring-beans.xsd + http://www.springframework.org/schema/integration/stream + https://www.springframework.org/schema/integration/stream/spring-integration-stream.xsd"> + + <int-stream:stdin-channel-adapter id="stdin" charset="UTF-8"/> + +</beans:beans>