Fix: `close()` muss noch vom `ExampleProducer` aufgerufen werden
authorKai Moritz <kai@juplo.de>
Fri, 1 Nov 2024 14:12:00 +0000 (15:12 +0100)
committerKai Moritz <kai@juplo.de>
Tue, 21 Jan 2025 20:13:37 +0000 (21:13 +0100)
commitb8b73fec897367226ea9b4764ca0d6c96d80c2bc
tree7833e495a63b0e3f86bd1549b882ecc56a919c81
parente9129d63e3b3c51eaf59d6643dc184358ba9576b
Fix: `close()` muss noch vom `ExampleProducer` aufgerufen werden

* Der Aufruf von `close()` löst das Versenden wartender Nachrichten aus.
* Wenn die Methode erst von Spring aufgerufen wird, werden ggf. noch
  Nachrichten konsumiert, nachdem der `ExampleProducer` bereits
  ausgegeben hat, wieviele Nachrichten er insgesamt verarbeitet hat.
src/main/java/de/juplo/kafka/ApplicationConfiguration.java
src/main/java/de/juplo/kafka/ExampleProducer.java