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>
Thu, 20 Feb 2025 18:30:51 +0000 (19:30 +0100)
commitd602cd5e963ab47645c5964ffb8565ae8254929d
treef351b13e02dac992ce12500d20ef54352b6f7d2a
parentf472b450132d6a6cfe2aa4cc12ef903a87ed60ab
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