projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: cc2c208) | patch
EndlessProducer in RestProducer umgearbeitet
authorKai Moritz <kai@juplo.de>
Fri, 25 Mar 2022 09:56:17 +0000 (10:56 +0100)
committerKai Moritz <kai@juplo.de>
Sat, 2 Apr 2022 20:40:07 +0000 (22:40 +0200)
commit50da4f6f74a8f4f567b7af8556480f81256c61dc
treefed30b0d5ceb70f4d4e220ae589f756399042877tree | snapshot
parentcc2c208dac22a61538f91638b3552b1b45500117commit | diff
EndlessProducer in RestProducer umgearbeitet

* Der Producer nimmt die zu versendende Nachricht über ein POST entgegen
* Als Schlüssel wird der Pfad des POST-Aufrufs verwendet
* Die Anfragen werden mit einem DeferredResult asynchron verarbeitet
* Der Producer antwortet erst mit 200-OK, wenn die Nachricht bestätigt wurde
* Wenn der Broker mit einem Fehler antwortet, wird 500 zurückgegeben
* Wenn der Broker nicht erreicht werden kann, wird 400 zurückgegeben
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 [deleted file] blob | history
src/main/java/de/juplo/kafka/ProduceFailure.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/ProduceResult.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/ProduceSuccess.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/RestProducer.java diff | blob | history
src/main/resources/application.yml diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.