X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fresources%2Fapplication.yml;h=bdcb44100fd6412e350cc252022b999462237e54;hb=7e38c678f43c975f2a58391bb32e1d044278e237;hp=40d0a85c968085a3a7dae241ff1d19bef69734c7;hpb=d0de5c9030e575251d62d2a207ede84cd881ccec;p=demos%2Fkafka%2Ftraining diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index 40d0a85..bdcb441 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -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