projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: efa9423) | patch
REST-Client implementiert, der Nachrichten über den REST-Producer verschickt
authorKai Moritz <kai@juplo.de>
Thu, 31 Mar 2022 08:58:46 +0000 (10:58 +0200)
committerKai Moritz <kai@juplo.de>
Sat, 2 Apr 2022 20:44:02 +0000 (22:44 +0200)
commitd1c1f40d2ad5f69e43ced0e278cf80dfc6ee21ef
treee9ae650a5049fa44314df57ca1cc67e00c6de3b4tree | snapshot
parentefa942341314e29f68b895ad4c8cee766c895236commit | diff
REST-Client implementiert, der Nachrichten über den REST-Producer verschickt

* Der Client versendet so wie der Endless-Producer eine monoton steigende
  Zahlenfolge
* Allerdings werden alle Nachrichten mit dem selben Schlüssel versendet
* Der Schlüssel wird über die Konfiguration festgelegt
* Die Nachrichten werden asynchron versendet
* Zwischen zwei Nachrichten wird eine konfigurierbare Pause eingehalten
* Dabei kommen die Defaults von Spring Boot zum Einsatz (4 Http-Threads)
* Die Antworten werden abgewartet und entsprechend ausgegeben
* Über REST-Endpoints können die bisher aufgetretenen Fehler und die noch
  ausstehenden Nachrichten abgefragt werden
13 files changed:
README.sh diff | blob | history
docker-compose.yml diff | blob | history
pom.xml diff | blob | history
src/main/java/de/juplo/kafka/Application.java diff | blob | history
src/main/java/de/juplo/kafka/ApplicationProperties.java diff | blob | history
src/main/java/de/juplo/kafka/DriverController.java diff | blob | history
src/main/java/de/juplo/kafka/EndlessProducer.java [deleted file] blob | history
src/main/java/de/juplo/kafka/RestClient.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/RestFailure.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/RestResult.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/RestService.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/RestSuccess.java [new file with mode: 0644] blob
src/main/resources/application.yml diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.