query: 2.0.0 - Values are serialized as JSON
authorKai Moritz <kai@juplo.de>
Tue, 11 Jun 2024 18:41:30 +0000 (20:41 +0200)
committerKai Moritz <kai@juplo.de>
Thu, 13 Jun 2024 15:24:00 +0000 (17:24 +0200)
commit0648885ec026d7434561060dc7edb703efea6853
tree1b1e3c80457fd7307f7f523de8cf69a48e93b49d
parent2f5828ee2bbd662c3c81c76961d00b871468c8b9
query: 2.0.0 - Values are serialized as JSON
--
works, still startling, but explainable

* Splitting the command ``table()``, that reads the input-topic and
  materializes it as ``KTable()``, into the two statements ``stream()``,
  that reads the input-topic into a ``KStream``, and ``toTable()``, that
  turns the `KStream` into a ``KTable``, the ``JsonSerde``, that is
  specified via ``Consumed.with(..)``, is only used for the serialization
  and deserialization concerning the ``KTable`` -- not the deserialization
  of the values, that are read from the input-topic.
* Hence, the type-mappings does not have to be specified for the
  ``JsonSerde``, resulting in better understandable code.
* __Note__, that the resulting topology does not differe, because the
  DSL is able to combine the effects of the two statements.
src/main/java/de/juplo/kafka/wordcount/query/QueryStreamProcessor.java