projects / demos / kafka / wordcount / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 8d0ef24) | patch
splitter: 1.0.0-spring-ingetration - added an interceptor for logging
authorKai Moritz <kai@juplo.de>
Mon, 18 Jul 2022 20:48:26 +0000 (22:48 +0200)
committerKai Moritz <kai@juplo.de>
Wed, 20 Jul 2022 18:36:53 +0000 (20:36 +0200)
commitf81962e03ef5ada8426fb069073ae38e877dd4ac
tree8b7ddddef60c58f8873ee8808f5eecd8b9dd0af1tree | snapshot
parent8d0ef2423c0f6ef6a439b98a1d9b1b1a64d89d45commit | diff
splitter: 1.0.0-spring-ingetration - added an interceptor for logging

* Added a global interceptor, that uses `WireTap` to copy the messages
  to a special channel for logging, named `messageLog`.
* Added a `LoggingHandler`, that logs the messages, that are accumulated
  in the new channel `messageLog`.
src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplication.java diff | blob | history
src/main/resources/application.properties diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.