]> juplo.de Git - demos/kafka/training/commit
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>
Sat, 18 Jan 2025 08:53:40 +0000 (09:53 +0100)
commitcec78da07f7140702ca4b9bd1c384320c8d5d8d0
treed9a02bc9b301477619ff63c54a890fd0c7e1b3f9
parent90f25f10730b5eabcac02fc3a147a592efa4cd11
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