diff --git a/multi-io-samples/kafka-streams/user-clicks-per-region-1.2.x/log-user-clicks-per-region/pom.xml b/multi-io-samples/kafka-streams/user-clicks-per-region-1.2.x/log-user-clicks-per-region/pom.xml index 6c4c67b..d7446e4 100644 --- a/multi-io-samples/kafka-streams/user-clicks-per-region-1.2.x/log-user-clicks-per-region/pom.xml +++ b/multi-io-samples/kafka-streams/user-clicks-per-region-1.2.x/log-user-clicks-per-region/pom.xml @@ -56,6 +56,11 @@ spel-function 1.0.3 + + org.springframework.cloud.fn + payload-converter-function + 1.0.3 + org.springframework.cloud.stream.app stream-applications-composite-function-support diff --git a/multi-io-samples/kafka-streams/user-clicks-per-region-1.2.x/log-user-clicks-per-region/src/main/resources/application.yml b/multi-io-samples/kafka-streams/user-clicks-per-region-1.2.x/log-user-clicks-per-region/src/main/resources/application.yml index c468657..3f8447c 100644 --- a/multi-io-samples/kafka-streams/user-clicks-per-region-1.2.x/log-user-clicks-per-region/src/main/resources/application.yml +++ b/multi-io-samples/kafka-streams/user-clicks-per-region-1.2.x/log-user-clicks-per-region/src/main/resources/application.yml @@ -1,4 +1,4 @@ -spring.cloud.function.definition: logConsumer +spring.cloud.function.definition: byteArrayTextToString|logConsumer spring.cloud.stream.function.bindings.logConsumer-in-0: input spring.cloud.stream.bindings.input.consumer.useNativeDecoding: true