projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 0b7c0ee) | patch
Handling der Nachricht in das Interface `RecordHandler` verlegt consumer/spring-consumer--record-handler--generics4all consumer/spring-consumer--record-handler--generics4some
authorKai Moritz <kai@juplo.de>
Fri, 21 Feb 2025 14:56:46 +0000 (15:56 +0100)
committerKai Moritz <kai@juplo.de>
Fri, 21 Feb 2025 14:56:46 +0000 (15:56 +0100)
commit11a92b79b8cb212728efd6f4e8d756ed9aa66cda
treeec2ce032bf49e4a5a564e9b885e2dbc05ea4be7etree | snapshot
parent0b7c0ee4b386f1da003c8c515965c1018278b447commit | diff
Handling der Nachricht in das Interface `RecordHandler` verlegt

* Tests für das Verhalten im Fehlerfall
* Der Payload einer Nachricht wird über alle Nachrichten hochgezählt
* Konfiguration über `ApplicationConiguration` - aber von Hand
src/main/java/de/juplo/kafka/ApplicationConfiguration.java diff | blob | history
src/main/java/de/juplo/kafka/ExampleConsumer.java diff | blob | history
src/main/java/de/juplo/kafka/RecordHandler.java [new file with mode: 0644] blob
src/test/java/de/juplo/kafka/ExampleConsumerTest.java [new file with mode: 0644] blob
src/test/java/de/juplo/kafka/MockRecordHandler.java [new file with mode: 0644] blob
Unnamed repository; edit this file 'description' to name the repository.