projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: b604f66) | patch
Producer liest nur Partition 0, stets von Offset 0 spring-consumer--topicpartition
authorKai Moritz <kai@juplo.de>
Sun, 13 Nov 2022 16:08:36 +0000 (17:08 +0100)
committerKai Moritz <kai@juplo.de>
Sun, 13 Nov 2022 17:03:44 +0000 (18:03 +0100)
commit7a9916194eb5d6ed2066692800aa1f6d6c9f0a9b
treea9f8c3ae36c830976dcda638f5a7427e901ad85btree | snapshot
parentb604f66480e03b0b5e915bb04feb886b00ba0f6bcommit | diff
Producer liest nur Partition 0, stets von Offset 0

* Der Producer benutzt jetzt `assign()`
* Da er sich beim Speichern der Offsets mit der Consumer-Group in die
  Quere kommt, muss auch die Group-ID angepasst werden!
src/main/java/de/juplo/kafka/SimpleConsumer.java diff | blob | history
src/main/resources/application.yml diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.