projects
/
demos
/
kafka
/
training
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Das Topic wird über `spring.kafka.template.default-topic` konfiguriert
[demos/kafka/training]
/
src
/
main
/
resources
/
application.yml
diff --git
a/src/main/resources/application.yml
b/src/main/resources/application.yml
index
f54576a
..
ce26258
100644
(file)
--- a/
src/main/resources/application.yml
+++ b/
src/main/resources/application.yml
@@
-18,7
+18,7
@@
info:
kafka:
bootstrap-servers: ${spring.kafka.bootstrap-servers}
client-id: ${producer.client-id}
kafka:
bootstrap-servers: ${spring.kafka.bootstrap-servers}
client-id: ${producer.client-id}
- topic: ${
producer.
topic}
+ topic: ${
spring.kafka.template.default-
topic}
acks: ${spring.kafka.producer.acks}
batch-size: ${spring.kafka.producer.batch-size}
linger-ms: ${spring.kafka.producer.properties.linger.ms}
acks: ${spring.kafka.producer.acks}
batch-size: ${spring.kafka.producer.batch-size}
linger-ms: ${spring.kafka.producer.properties.linger.ms}
@@
-40,6
+40,8
@@
spring:
message:de.juplo.kafka.ClientMessage,
foo:de.juplo.kafka.FooMessage,
greeting:de.juplo.kafka.Greeting
message:de.juplo.kafka.ClientMessage,
foo:de.juplo.kafka.FooMessage,
greeting:de.juplo.kafka.Greeting
+ template:
+ default-topic: test
logging:
level:
root: INFO
logging:
level:
root: INFO