summary |
shortlog | log |
commit |
commitdiff |
tree
first ⋅ prev ⋅ next
Kai Moritz [Sun, 17 Jul 2022 16:05:37 +0000 (18:05 +0200)]
WIP
Kai Moritz [Sun, 17 Jul 2022 15:58:09 +0000 (17:58 +0200)]
WIP
Kai Moritz [Sun, 17 Jul 2022 15:55:05 +0000 (17:55 +0200)]
WIP
Kai Moritz [Sun, 17 Jul 2022 15:42:42 +0000 (17:42 +0200)]
WIP
Kai Moritz [Thu, 30 Jun 2022 19:45:23 +0000 (21:45 +0200)]
WIP
Kai Moritz [Sun, 17 Jul 2022 15:23:28 +0000 (17:23 +0200)]
WIP
Kai Moritz [Sun, 17 Jul 2022 15:18:40 +0000 (17:18 +0200)]
Merge branch 'splitter-spring-integration' into splitter-spring-integration-xml
* The configuration can be simplified
* The `ChannelInterceptor` can be omitted, if a `message-key-expression`
is specivied for the outbound channel.
* The explicit definition of the `DirectChannel` is not needed any more.
Kai Moritz [Sun, 17 Jul 2022 15:11:03 +0000 (17:11 +0200)]
splitter: 1.0.0-spring-ingetration - using a `message-key-expression`
* The configuration can be simplified
* The `ChannelInterceptor` can be omitted, if a `message-key-expression`
is specivied for the outbound channel.
Kai Moritz [Thu, 30 Jun 2022 14:46:39 +0000 (16:46 +0200)]
splitter: 1.0.0-spring-integration-xml - defined the `DirectChannel` in XML
Kai Moritz [Thu, 30 Jun 2022 19:34:21 +0000 (21:34 +0200)]
splitter: 1.0.0-spring-integration - refactored configuration
Kai Moritz [Sun, 26 Jun 2022 16:07:32 +0000 (18:07 +0200)]
splitter: 1.0.0-spring-integration - Added the key of the incoming message
* Added a `ChannelInterceptor`, that copies the key from the received
message to the outgoing message.
* This fixes the test.
Kai Moritz [Sun, 26 Jun 2022 12:05:11 +0000 (14:05 +0200)]
splitter: 1.0.0-spring-integration - Inital implementation (incomplete)
* "Implementing" the splitter with Spring Integration mainly is a
configuration task.
* This version does not yet send the messages with the correct key.
* Managment of transactions is not yet considered.
* The test fails, because the key is missing.
Kai Moritz [Thu, 30 Jun 2022 17:06:09 +0000 (19:06 +0200)]
splitter: Implemented a test that proofs the splitting process
Kai Moritz [Thu, 30 Jun 2022 16:53:46 +0000 (18:53 +0200)]
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.
Kai Moritz [Sun, 26 Jun 2022 11:05:46 +0000 (13:05 +0200)]
splitter: 1.0.0-vanilla-kafka - Factored out splitting logic
Kai Moritz [Sun, 26 Jun 2022 08:54:39 +0000 (10:54 +0200)]
splitter: 1.0.0-vanilla-kafka - Fixed the test "Context Loads"
* Added `spring-kafka-test` as dependency.
* Added `@EmbeddedKafka` to the integration test.
* Configured the test to support transactions (replication factor == 1).
* Fixed the `SplitterStreamProcessor`: the application logic is executed
in a background thread, because it blocks the startup of Spring Boot
otherwise.
Kai Moritz [Sun, 26 Jun 2022 07:39:12 +0000 (09:39 +0200)]
splitter: 1.0.0-vanilla-kafka - upgraded Spring Boot to 2.7.2
Kai Moritz [Fri, 27 May 2022 12:38:43 +0000 (14:38 +0200)]
splitter: 1.0.0-vanilla-kafka - splits up the recorded sentences into words
* Simple implementation of the splitter without Kafka Streams
* This version does not record its position
* Hence, in case of an error, it will most likly reprocess some messages,
leading to wrong countings
Kai Moritz [Sat, 16 Oct 2021 14:39:52 +0000 (16:39 +0200)]
recorder: 1.0.1 - changed default-port and exposed all actuator-endpoints
Kai Moritz [Wed, 1 Sep 2021 16:42:29 +0000 (18:42 +0200)]
recorder:1.0.0 - send recordings keyed by username
Kai Moritz [Wed, 1 Sep 2021 15:49:48 +0000 (17:49 +0200)]
Generated empty project on start.spring.io
projects / demos / kafka / wordcount / log