projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 2768e0f) | patch
Benennung vereinheitlicht und projektunabhängig gemacht
authorKai Moritz <kai@juplo.de>
Sun, 14 Aug 2022 17:11:25 +0000 (19:11 +0200)
committerKai Moritz <kai@juplo.de>
Sun, 14 Aug 2022 17:33:27 +0000 (19:33 +0200)
commit4abc82d5d4cc80feabee91a10749b40f9bcfd879
treeb81a6434105d8e4d442f12e72ecfc34ef5ae2e4ctree | snapshot
parent2768e0f97c441ade5ce8ff371aa590fdc3cfd6c6commit | diff
Benennung vereinheitlicht und projektunabhängig gemacht
12 files changed:
src/main/java/de/juplo/kafka/ApplicationConfiguration.java diff | blob | history
src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/ApplicationRecordHandler.java [new file with mode: 0644] blob
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/KeyCountingRebalanceListener.java [deleted file] blob | history
src/main/java/de/juplo/kafka/KeyCountingRecordHandler.java [deleted file] blob | history
src/main/java/de/juplo/kafka/PartitionStatisticsRepository.java [deleted file] blob | history
src/main/java/de/juplo/kafka/StateDocument.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/StateRepository.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/StatisticsDocument.java [deleted file] blob | history
src/test/java/de/juplo/kafka/ApplicationTests.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.