Config tweaks

gAmUssA · Feb 11, 2020 · 05d8039 · 05d8039
1 parent 5274359
commit 05d8039
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 2 deletions.
diff --git 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
@@ -26,4 +26,20 @@ spring:
       default-topic:
 logging:
   level:
-    root: info
+    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