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>
Wed, 22 Jan 2025 21:50:49 +0000 (22:50 +0100)
commit216783fa9768ce48e8f2d2a33e358a12ea22946e
tree7f4e64d683b7a2916c2dd9b738018421a0169f2f
parent0a9253beb96726a337a1938958ef891ad198ed77
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