From: Kai Moritz <kai@juplo.de>
Date: Sun, 26 Jun 2022 07:32:49 +0000 (+0200)
Subject: TOD
X-Git-Tag: bytestream-producer
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=ddb17783b554625ffa7050f91f004784263e0efe;p=demos%2Fkafka%2Ftraining

TOD
---

diff --git a/TOD.txt b/TOD.txt
new file mode 100644
index 0000000..70adc76
--- /dev/null
+++ b/TOD.txt
@@ -0,0 +1,13 @@
+Dieser Ansatz wurde erst mal verworfen!
+
+* Es geht hier nur darum, Daten einzulesen und in einen Channel zu schreiben
+* Die Idee, dafür die Stream-Abstraktion von Integration zu verwenden,
+  passt aus mehreren Gründen schlecht zum gewählten Beispiel:
+  * Es könnten hier nur Datenblobs erzeugt werden und nicht, analog zu
+    den anderen Implementierungs-Beispielen, die unterschiedlichen
+    Nachrichten-Typen.
+  * Wenn überhaupt so möglich, wie angedacht, müsste mit der Stream-
+    Abstraktion ein Channel mit Daten-Blobs erzeugt werden, der dann
+    von einem Filter verarbeitet wird, der aus den Daten-Blobs die
+    erwarteten Nachrichten-Typen erzeugt.
+* ...
diff --git a/src/main/java/de/juplo/kafka/IntegrationConfiguration.java b/src/main/java/de/juplo/kafka/IntegrationConfiguration.java
new file mode 100644
index 0000000..624e9ef
--- /dev/null
+++ b/src/main/java/de/juplo/kafka/IntegrationConfiguration.java
@@ -0,0 +1,11 @@
+package de.juplo.kafka;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.integration.config.EnableIntegration;
+
+
+@Configuration
+@EnableIntegration
+public class IntegrationConfiguration
+{
+}
diff --git a/src/main/resources/integration.xml b/src/main/resources/integration.xml
deleted file mode 100644
index 2b22bcd..0000000
--- a/src/main/resources/integration.xml
+++ /dev/null
@@ -1,12 +0,0 @@
-<?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>