WIP

diff --git a/src/main/resources/integration.xml b/src/main/resources/integration.xml
index 4ecea8b..fc161e4 100644 (file)
--- a/src/main/resources/integration.xml
+++ b/src/main/resources/integration.xml
@@ -8,11 +8,10 @@
                http://www.springframework.org/schema/integration https://www.springframework.org/schema/integration/spring-integration.xsd
         http://www.springframework.org/schema/integration/kafka http://www.springframework.org/schema/integration/kafka/spring-integration-kafka.xsd">
 
-  <int-kafka:inbound-channel-adapter
-      id="recordings"
-      consumer-factory="kafkaConsumerFactory"
-      payload-type="java.lang.String"
-      group-id="splitter"
-      channel="recordings" />
+  <int-kafka:outbound-channel-adapter
+      id="words"
+      kafka-template="kafkaTemplate"
+      topic-expression="${juplo.wordcount.splitter.output-topic}"
+      message-key-expression="headers['kafka_receivedMessageKey']" />
 
 </beans>