query: 2.0.0 - Values are serialized as JSON
authorKai Moritz <kai@juplo.de>
Tue, 11 Jun 2024 18:36:58 +0000 (20:36 +0200)
committerKai Moritz <kai@juplo.de>
Thu, 13 Jun 2024 15:23:44 +0000 (17:23 +0200)
commit2f5828ee2bbd662c3c81c76961d00b871468c8b9
tree05f83a8f109e155e0aff2234623bcca4a43f18b8
parent278c7b8125c82120e1d80fa640bd16d375d4bf86
query: 2.0.0 - Values are serialized as JSON
--
works, but is very confusing

* The default-type is specified as a consumption-parameter in the command,
  that reads the input topic into the `KTable` via ``Consumed.with(..)``.
* The resulting code is confusing, because the ``Consumed``-parameter is
  used for both, the consumption of the input topic _and_ the consumption
  of stored values, if read from the state-store.
* Because of this, one might only think of the consumption of the stored
  values from the state-store, when looking at the ``Consumed.with()``-
  statement, and argue, why the type-mappings have to be specified here.
src/main/java/de/juplo/kafka/wordcount/query/QueryApplicationConfiguration.java
src/main/java/de/juplo/kafka/wordcount/query/QueryStreamProcessor.java