]> juplo.de Git - demos/kafka/training/commit
projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: cd9c849) | patch
Fehler korrigiert: Shutdown wartet auf Versand der wartenden Nachrichten
authorKai Moritz <kai@juplo.de>
Sun, 15 Mar 2026 10:48:08 +0000 (11:48 +0100)
committerKai Moritz <kai.milan.moritz@googlemail.com>
Fri, 12 Jun 2026 17:17:32 +0000 (19:17 +0200)
commit646554fcc06b9a0a62cdf6fbadcba5820f9cdb1e
tree1664f6bf1f32f6eb2202c8f1cbd7f459be145b44tree | snapshot
parentcd9c849469a045fbee0650bcd9695d374fd3687ecommit | diff
Fehler korrigiert: Shutdown wartet auf Versand der wartenden Nachrichten

* Über die Verwendung einer Semaphore wird sichergestellt, dass alle
  für das Queuing übergebenen Nachrichten auch an Kafka übergeben werden,
  bevor `KafkaProducer.close()` aufgerufen wird
* Ansonsten wurden geschedulte Nachrichten teilweise erst an den Producer
  übergeben, nachdem dieser bereits geschlossen wurde, so dass es zu
  Fehlern gekommen ist.
src/main/java/de/juplo/kafka/ExampleProducer.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.