projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 11eeba5) | patch
Aligned the example with the example for a Sliding Window
authorKai Moritz <kai@juplo.de>
Wed, 17 Jul 2024 17:20:38 +0000 (19:20 +0200)
committerKai Moritz <kai@juplo.de>
Wed, 17 Jul 2024 17:20:38 +0000 (19:20 +0200)
commit656d4fb60f19d218726e36f27d25ec896a35ddae
treee50b86abb72ee8c5476fa9ca94b0911af1d483f0tree | snapshot
parent11eeba55d369e14e0bef1f6f32a6efa4a570ef05commit | diff
Aligned the example with the example for a Sliding Window

* *Note:* Both examples need an explicit configuration for the
  materialization of the state as store, when suppression is activated!
src/test/java/de/juplo/kafka/wordcount/counter/AggregationTopologyTest.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.