projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 459f640) | patch
Für das Versenden wird das `KafkaTemplate` von Spring verwendet
authorKai Moritz <kai@juplo.de>
Sun, 12 Jun 2022 08:43:50 +0000 (10:43 +0200)
committerKai Moritz <kai@juplo.de>
Sun, 12 Jun 2022 13:47:35 +0000 (15:47 +0200)
commit96013a5bc40a65eb35713bccc756eea03c4f3de7
tree5e7e999cc2e87b756bf2dd7de33e8780db97656etree | snapshot
parent459f64072f3b657990a3bda0d39306208702d537commit | diff
Für das Versenden wird das `KafkaTemplate` von Spring verwendet

* Dabei wird weiterhin ein `ProducerRecord` erzeugt und dem
  `KafkaTemplate` übergeben, um die Änderungen möglichst übersichtlich
  zu halten.
* Die zuvor über `ApplicationProperties` einstellbaren Parameter wurden
  in der `application.yml` entsprechend in dem `spring.kafka.*`-Namespace
  gesetzt.
* Eintragung in den per Actuator veröffentlichten Infos angepasst.
docker-compose.yml diff | blob | history
src/main/java/de/juplo/kafka/ApplicationProperties.java diff | blob | history
src/main/java/de/juplo/kafka/ProduceFailure.java diff | blob | history
src/main/java/de/juplo/kafka/RestProducer.java diff | blob | history
src/main/resources/application.yml diff | blob | history
src/test/java/de/juplo/kafka/ApplicationTests.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.