From 05d803904f15895fd9818d2577e747b6c104c89e Mon Sep 17 00:00:00 2001
From: Viktor Gamov <viktor@confluent.io>
Date: Tue, 11 Feb 2020 11:48:51 -0500
Subject: [PATCH] Config tweaks

---
 src/main/resources/application-cloud.yaml |  2 +-
 src/main/resources/application.yaml       | 18 +++++++++++++++++-
 2 files changed, 18 insertions(+), 2 deletions(-)

diff --git a/src/main/resources/application-cloud.yaml b/src/main/resources/application-cloud.yaml
index 13e8858..a9c2c75 100644
--- a/src/main/resources/application-cloud.yaml
+++ b/src/main/resources/application-cloud.yaml
@@ -1,6 +1,6 @@
 # This profile will be used in CF environment 
 topic:
-  name: viktor-users
+  name: users
   partitions-num: 6
   replication-factor: 3
 server:
diff --git a/src/main/resources/application.yaml b/src/main/resources/application.yaml
index 8eb4481..5438ce9 100644
--- a/src/main/resources/application.yaml
+++ b/src/main/resources/application.yaml
@@ -26,4 +26,20 @@ spring:
       default-topic:
 logging:
   level:
-    root: info
\ No newline at end of file
+    root: info
+    
+# spring cloud streams    
+spring.cloud.stream.kafka.streams.binder.configuration.commit.interval.ms: 1000
+spring.cloud.stream.kafka.streams:
+  binder.configuration:
+    default.key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde
+    default.value.serde: io.confluent.kafka.streams.serdes.avro.SpecificAvroSerde
+  bindings.users.consumer.application-id: user-filter
+spring.cloud.stream.bindings.users-filtered:
+  destination: users-filtered
+  producer:
+    useNativeEncoding: true
+spring.cloud.stream.bindings.users:
+  destination: users
+  consumer:
+    useNativeDecoding: true