counter: 1.3.0 - (RED) Introduced domain-class `User` as key
authorKai Moritz <kai@juplo.de>
Wed, 5 Jun 2024 19:30:17 +0000 (21:30 +0200)
committerKai Moritz <kai@juplo.de>
Sat, 8 Jun 2024 11:33:30 +0000 (13:33 +0200)
commite6198710fe679bc7463d1b17c9d9dc311062ef31
tree5ce4cc98e808b1e097b1a64de6fe03565e5c2608
parent8d0426539d69616900f4d6ef19e52d50b497f57f
counter: 1.3.0 - (RED) Introduced domain-class `User` as key

* _GREEN:_ The `CounterApplicationIT` does _not_ reveal the bug!
* _RED:_ The `CounterStreamProcessorToplogyTest` fails with an exception,
  that gives a hint for the cause of the bug.
* The bug is caused by missing type-specifications for the operation
  ``cout()``.
* Before the introduction of the domain-class `User` everything worked as
  expected, because the class `Word` could be specified as default for
  the deserialization of the key.
** With the introduction of the domain-class `User` as key of the incoming
   messages, the default for the key has to switched to this class, to
   enable the application to deserialize incomming keys despite the missing
   type mapping.
** Beforehand, the default `Word` covered the missing type information
   for the ``count()``-operator.
pom.xml
src/main/java/de/juplo/kafka/wordcount/counter/CounterApplicationConfiguriation.java
src/main/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessor.java
src/main/java/de/juplo/kafka/wordcount/counter/User.java [new file with mode: 0644]
src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
src/test/java/de/juplo/kafka/wordcount/counter/CounterStreamProcessorTopologyTest.java
src/test/java/de/juplo/kafka/wordcount/counter/TestData.java
src/test/java/de/juplo/kafka/wordcount/splitter/TestInputUser.java [new file with mode: 0644]