projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 55d9c92) | patch
splitter: 1.0.0-vanilla-kafka - Fixed shutdown
authorKai Moritz <kai@juplo.de>
Thu, 30 Jun 2022 16:53:46 +0000 (18:53 +0200)
committerKai Moritz <kai@juplo.de>
Thu, 30 Jun 2022 18:13:51 +0000 (20:13 +0200)
commita3144e93ad95a87cfb33d261c2f6eb67062734c1
tree63c922ca6b607fdaed68c69a8e3c96556765d616tree | snapshot
parent55d9c923b04389ed5c6b9d6794587fa794384a5fcommit | diff
splitter: 1.0.0-vanilla-kafka - Fixed shutdown

* The shutdown was blocked, because tSplitterStreamProcessor.stop()
  was called twice.
* The second time, it could no longer reach the cluster, hence, blocking
  the shutdown process.
src/main/java/de/juplo/kafka/wordcount/splitter/SplitterStreamProcessor.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.