projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: a6a0a22) | patch
refactor: Implementierung an Branch `stored-offsets` angepasst
authorKai Moritz <kai@juplo.de>
Thu, 11 Aug 2022 18:52:35 +0000 (20:52 +0200)
committerKai Moritz <kai@juplo.de>
Fri, 12 Aug 2022 14:45:21 +0000 (16:45 +0200)
commit2d84eda74475aaffff11ddfebe56d309b9aff2e9
treead9f3ac79187eddfe66e4a57d9195ad11577cf6ctree | snapshot
parenta6a0a22a5fa34a01b0e8b2bc1e0e2b82d7b60f33commit | diff
refactor: Implementierung an Branch `stored-offsets` angepasst
src/main/java/de/juplo/kafka/ApplicationConfiguration.java diff | blob | history
src/main/java/de/juplo/kafka/ApplicationHealthIndicator.java diff | blob | history
src/main/java/de/juplo/kafka/DriverController.java diff | blob | history
src/main/java/de/juplo/kafka/EndlessConsumer.java diff | blob | history
src/main/java/de/juplo/kafka/RecordHandler.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/WordcountRecordHandler.java [new file with mode: 0644] blob
src/test/java/de/juplo/kafka/ApplicationTests.java diff | blob | history
src/test/java/de/juplo/kafka/TestRecordHandler.java [new file with mode: 0644] blob
Unnamed repository; edit this file 'description' to name the repository.