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>
Fri, 8 Nov 2024 17:06:36 +0000 (18:06 +0100)
commit86e9cb9939ed99ed48acebdee06dc6c84a67b09c
treecf691f70872c1922bb64dc8cfade7c2ba377bd57
parent0de7a5a8ecb8fbabf49b7145285a2245ca14eb54
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