projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 656d24e) | patch
Parameter `partition` wiederbelebt sumup-gateway---lvm-2-tage
authorKai Moritz <kai@juplo.de>
Wed, 17 Aug 2022 16:43:43 +0000 (18:43 +0200)
committerKai Moritz <kai@juplo.de>
Wed, 17 Aug 2022 16:43:45 +0000 (18:43 +0200)
commit6d6877ff078d4fa9d4709f8ff497488abded231b
tree0b2015e3bd6e151a9a7c6d88c2fd8b7e492e2551tree | snapshot
parent656d24e02b7e42404a508946885009b59b39e1eecommit | diff
Parameter `partition` wiederbelebt

* Wenn der Parameter gesetzt ist, schreibt das Gateway alle Nachrichten
  in die vorgegebene Partition.
* Wenn der Parameter null ist, wird die Default-Partitionierung
  (Hashing by Key) verwendet.
src/main/java/de/juplo/kafka/ApplicationConfiguration.java diff | blob | history
src/main/java/de/juplo/kafka/ApplicationProperties.java diff | blob | history
src/main/java/de/juplo/kafka/RestGateway.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.