demos/kafka/wordcount
2 weeks agotop10: 1.2.1 - Refined `TestData` clearified concerns
Kai Moritz [Sat, 8 Jun 2024 16:37:55 +0000 (18:37 +0200)]
top10: 1.2.1 - Refined `TestData` clearified concerns

2 weeks agotop10: 1.2.1 - Fixed race-condition in `Top10ApplicationIT`
Kai Moritz [Sat, 8 Jun 2024 16:30:28 +0000 (18:30 +0200)]
top10: 1.2.1 - Fixed race-condition in `Top10ApplicationIT`

2 weeks agotop10: 1.2.1 - `Top10ApplicationIT` asserts type-mapping for output-data
Kai Moritz [Sat, 8 Jun 2024 16:18:41 +0000 (18:18 +0200)]
top10: 1.2.1 - `Top10ApplicationIT` asserts type-mapping for output-data

2 weeks agotop10: 1.2.1 - Fixed possible NPE in `Top10ApplicationIT`
Kai Moritz [Sat, 8 Jun 2024 17:35:21 +0000 (19:35 +0200)]
top10: 1.2.1 - Fixed possible NPE in `Top10ApplicationIT`

2 weeks agotop10: 1.2.1 - `TestData` uses faked foreign classes for input-/output data
Kai Moritz [Sat, 8 Jun 2024 13:19:23 +0000 (15:19 +0200)]
top10: 1.2.1 - `TestData` uses faked foreign classes for input-/output data

2 weeks agotop10: 1.2.1 - Simplified setup of `Top10StreamProcessorToplogyTest`
Kai Moritz [Sat, 8 Jun 2024 16:05:45 +0000 (18:05 +0200)]
top10: 1.2.1 - Simplified setup of `Top10StreamProcessorToplogyTest`

2 weeks agotop10: 1.2.1 - Introduced `TestUser`
Kai Moritz [Sat, 8 Jun 2024 13:04:31 +0000 (15:04 +0200)]
top10: 1.2.1 - Introduced `TestUser`

2 weeks agotop10: 1.2.1 - The name of the state-store is an internal detail
Kai Moritz [Sat, 8 Jun 2024 11:20:52 +0000 (13:20 +0200)]
top10: 1.2.1 - The name of the state-store is an internal detail

2 weeks agotop10: 1.2.1 - Removed logging of type-headers in tests
Kai Moritz [Mon, 3 Jun 2024 08:00:33 +0000 (10:00 +0200)]
top10: 1.2.1 - Removed logging of type-headers in tests

2 weeks agotop10: 1.2.1 - Refined `Top10StreamProcessorTopologyTest`
Kai Moritz [Mon, 3 Jun 2024 07:53:25 +0000 (09:53 +0200)]
top10: 1.2.1 - Refined `Top10StreamProcessorTopologyTest`

2 weeks agotop10: 1.2.1 - Added expectations for the number of received messages
Kai Moritz [Sun, 2 Jun 2024 09:45:30 +0000 (11:45 +0200)]
top10: 1.2.1 - Added expectations for the number of received messages

2 weeks agotop10: 1.2.1 - Added expectations for the final state in the last message
Kai Moritz [Sun, 2 Jun 2024 09:10:21 +0000 (11:10 +0200)]
top10: 1.2.1 - Added expectations for the final state in the last message

2 weeks agotop10: 1.2.1 - Refined assertion of expected state
Kai Moritz [Sun, 2 Jun 2024 09:00:36 +0000 (11:00 +0200)]
top10: 1.2.1 - Refined assertion of expected state

2 weeks agotop10: 1.2.1 - DRY for `User` in `TestData`
Kai Moritz [Sun, 2 Jun 2024 08:58:24 +0000 (10:58 +0200)]
top10: 1.2.1 - DRY for `User` in `TestData`

2 weeks agotop10: 1.2.1 - (GREEN) Made the aggregation state accessible
Kai Moritz [Thu, 30 May 2024 09:01:27 +0000 (11:01 +0200)]
top10: 1.2.1 - (GREEN) Made the aggregation state accessible

* The assertion, regarding the expected state, is true for both tests.
* The assertion, regarding the expected messages, ix only true for the
  test that is based on the `TopologyTestDriver`.
* _This highlights the need for an additional integration test to avoid
  misinterpretation of the results of tests, that are based on the
  ``TopologyTestDriver``.
* _Note,_ that the assertion, regarding the expected state, works as
  well in the `Top10ApplicationIT`, if the output buffering is enabled,
  because the changed state becomes visible immediately.
* The buffering ist still turned of, so that the disabled test can be
  run in IntelliJ to comprehend, that the assertion is actually false.

2 weeks agotop10: 1.2.1 - (RED) Added an assertion regarding the expected state
Kai Moritz [Thu, 30 May 2024 09:50:56 +0000 (11:50 +0200)]
top10: 1.2.1 - (RED) Added an assertion regarding the expected state

2 weeks agotop10: 1.2.1 - (RED) Fixed de-/serialization, turned of caching in IT
Kai Moritz [Sun, 26 May 2024 07:07:48 +0000 (09:07 +0200)]
top10: 1.2.1 - (RED) Fixed de-/serialization, turned of caching in IT

* Fixed the type-mapping for the `JsonDeserializer`.
* Disabled the caching / out-buffering in Streams.
* Both changes are necessary, to see in `Top10ApplicationIT`, that
  messages are processed: _Compare the outcome of the test before and
  after this commit!_
* Nonetheless, the integration-test still fails, because the assertion
  is not true.

2 weeks agotop10: 1.2.1 - (RED) Implemented integration-test `Top10ApplicationIT`
Kai Moritz [Mon, 27 May 2024 21:32:49 +0000 (23:32 +0200)]
top10: 1.2.1 - (RED) Implemented integration-test `Top10ApplicationIT`

3 weeks agotop10: 1.2.0 - Switched the message-key from `String` to `User` top10-1.2.0
Kai Moritz [Tue, 28 May 2024 20:59:38 +0000 (22:59 +0200)]
top10: 1.2.0 - Switched the message-key from `String` to `User`

3 weeks agotop10: 1.1.3 - (GREEN) Implemented `Ranking.equals()` accordingly top10-1.1.3
Kai Moritz [Tue, 28 May 2024 19:03:11 +0000 (21:03 +0200)]
top10: 1.1.3 - (GREEN) Implemented `Ranking.equals()` accordingly

3 weeks agotop10: 1.1.3 - (RED) Formulated expectations for `Ranking.equals()`
Kai Moritz [Tue, 28 May 2024 18:29:18 +0000 (20:29 +0200)]
top10: 1.1.3 - (RED) Formulated expectations for `Ranking.equals()`

3 weeks agotop10: 1.1.2 - (GREEN) Fixed implementation of `Ranking` top10-1.1.2
Kai Moritz [Sat, 25 May 2024 15:10:39 +0000 (17:10 +0200)]
top10: 1.1.2 - (GREEN) Fixed implementation of `Ranking`

3 weeks agotop10: 1.1.2 - (RED) Explicitly formulated expectations for `Ranking`
Kai Moritz [Sat, 25 May 2024 08:17:57 +0000 (10:17 +0200)]
top10: 1.1.2 - (RED) Explicitly formulated expectations for `Ranking`

3 weeks agotop10: 1.1.2 - (RED) `ToplogyTestDriver.close` must always be called
Kai Moritz [Mon, 27 May 2024 20:56:48 +0000 (22:56 +0200)]
top10: 1.1.2 - (RED) `ToplogyTestDriver.close` must always be called

* If the `TopologyTestDriver` is _not_ closed, it leaves behind the
  created RocksDB.
* Hence, the test will fail, if it changes state and expects a clean
  slate in the beginning.
* Therefore, the call to `close()` should happen in `@AfterEach`!

3 weeks agotop10: 1.1.2 - (RED) Added test, that asserts the expectated processing
Kai Moritz [Sat, 25 May 2024 14:59:42 +0000 (16:59 +0200)]
top10: 1.1.2 - (RED) Added test, that asserts the expectated processing

3 weeks agotop10: 1.1.1 - Upgraded Java & Kafka top10-1.1.1
Kai Moritz [Sat, 25 May 2024 14:56:31 +0000 (16:56 +0200)]
top10: 1.1.1 - Upgraded Java & Kafka

3 weeks agotop10: 1.1.0 - Simplified topology, using JsonSerde top10-1.1.0
Kai Moritz [Sun, 5 May 2024 12:55:17 +0000 (14:55 +0200)]
top10: 1.1.0 - Simplified topology, using JsonSerde

- Defined `JsonSerde` as default for keys and values.
- Removed the configuration of specific serdes from all steps of the
  processor-topology.
- Added type-mappings for serialization/deserialization.

6 weeks agotop10: 1.0.3 - Separated config in `Top10ApplicationConfiguration` -- ALIGN top10-1.0.3
Kai Moritz [Tue, 14 May 2024 21:04:50 +0000 (23:04 +0200)]
top10: 1.0.3 - Separated config in `Top10ApplicationConfiguration` -- ALIGN

6 weeks agotop10: 1.0.3 - Separated config in `Top10ApplicationConfiguration` -- COPY
Kai Moritz [Tue, 14 May 2024 21:02:55 +0000 (23:02 +0200)]
top10: 1.0.3 - Separated config in `Top10ApplicationConfiguration` -- COPY

7 weeks agotop10: 1.0.2 - Updated Spring Boot to `3.2.5` top10-1.0.2
Kai Moritz [Sun, 5 May 2024 09:16:37 +0000 (11:16 +0200)]
top10: 1.0.2 - Updated Spring Boot to `3.2.5`

2 years agotop10: 1.0.1 - changed default-port and exposed all actuator-endpoints top10-1.0.1
Kai Moritz [Sat, 16 Oct 2021 14:43:02 +0000 (16:43 +0200)]
top10: 1.0.1 - changed default-port and exposed all actuator-endpoints

2 years agotop10:1.0.0 - ranks first 10 mostly used words, keyed by user top10-1.0.0
Kai Moritz [Sat, 4 Sep 2021 15:20:44 +0000 (17:20 +0200)]
top10:1.0.0 - ranks first 10 mostly used words, keyed by user

2 years agowordcount:1.0.0 - counts words, keyed by username and word counter-1.0.0
Kai Moritz [Wed, 1 Sep 2021 20:31:01 +0000 (22:31 +0200)]
wordcount:1.0.0 - counts words, keyed by username and word