WIP
[demos/kafka/training] / src / main / resources / application.yml
index 40d0a85..bdcb441 100644 (file)
@@ -1,3 +1,6 @@
+sumup:
+  gateway:
+    topic: test
 management:
   endpoint:
     shutdown:
@@ -18,7 +21,7 @@ info:
     group-id: ${spring.kafka.consumer.group-id}
     auto-offset-reset: ${spring.kafka.consumer.auto-offset-reset}
     auto-commit-interval-ms: ${spring.kafka.consumer.properties.auto.commit.interval.ms}
-    topic: ${spring.kafka.template.default-topic}
+    topic: ${sumup.gateway.topic}
     acks: ${spring.kafka.producer.acks}
     batch-size: ${spring.kafka.producer.batch-size}
     linger-ms: ${spring.kafka.producer.properties.linger.ms}
@@ -37,7 +40,7 @@ spring:
       batch-size: 16384
       compression-type: gzip
       key-serializer: org.apache.kafka.common.serialization.StringSerializer
-      value-serializer: org.springframework.kafka.support.serializer.IntegerSerializer
+      value-serializer: org.apache.kafka.common.serialization.IntegerSerializer
       properties:
         linger.ms: 0
         delivery.timeout.ms: 20000 # 20 Sekunden