projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 419be8a) | patch
counter: 1.3.1 - Refined `CounterStreamProcessor` (serde-config)
authorKai Moritz <kai@juplo.de>
Sun, 16 Jun 2024 19:08:01 +0000 (21:08 +0200)
committerKai Moritz <kai@juplo.de>
Sun, 16 Jun 2024 19:18:32 +0000 (21:18 +0200)
commitbdd62b6b906db3b10ae04d2b4c80e6426a90ad7f
treec683e1b5757b012faf0a203f4befd6069d11dc12tree | snapshot
parent419be8ac0668ecb0e34b3a432cf2dcca1c3642dccommit | diff
counter: 1.3.1 - Refined `CounterStreamProcessor` (serde-config)

* Refactored the creation of the ``JsonSerde``s, that are used to consume
  the incomming messages.
* All special ``Serdes``, that are used for incomming and outgoing messages,
  are created in separted methods now.
* Removed unnecessary operatorx in the ``Materialized``-configuration for
  the state store (the operator is not necessary, because no headers are
  present, when deserializing from a store).
src/main/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessor.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.