projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: fd0c7ed) | patch
fix: Errors during shard-publishing should not kill the instance
authorKai Moritz <kai@juplo.de>
Mon, 26 Feb 2024 18:55:19 +0000 (19:55 +0100)
committerKai Moritz <kai@juplo.de>
Mon, 26 Feb 2024 19:41:55 +0000 (20:41 +0100)
commit13f86063f851fc2c4ad6de56c8edb78bff9d0592
tree4d366a292915ccc14427bae12e4311d14b4aed87tree | snapshot
parentfd0c7edb6ca97b53a13d8e6d1bf5149d53d36a5fcommit | diff
fix: Errors during shard-publishing should not kill the instance

* `HaproxyShardingPublisherStrategy` has to transform any exception into
  a `Mono.error()`.
* `DataChannel.onPartitionsAssigned(..)` has to log and swallow errors
  during the propagation of the shard-ownership.
src/main/java/de/juplo/kafka/chat/backend/implementation/haproxy/HaproxyShardingPublisherStrategy.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/DataChannel.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.