projects / demos / kafka / chat / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: bab48fa) | patch
feat: Implemented `HaproxyShardingPublisherStrategy`
authorKai Moritz <kai@juplo.de>
Sun, 17 Sep 2023 09:31:22 +0000 (11:31 +0200)
committerKai Moritz <kai@juplo.de>
Tue, 20 Feb 2024 09:35:33 +0000 (10:35 +0100)
commit3e7e62678fdcdc2d89179ccc16bd10709bf1e499
treeb16d45bf64ccd48a7c78b6eed04c446d74c02e19tree | snapshot
parentbab48fac3824b1dbf660881e5c517dc98ab9cc8fcommit | diff
feat: Implemented `HaproxyShardingPublisherStrategy`

* Implemented a first simple `ShardingPublisherStrategy`, that uses the
 https://www.haproxy.com/documentation/haproxy-runtime-api/[HAProxy Runntime API]
 to publish changed ownerships.
* Added configuration-properties `kafka.haproxyRuntimeApi` and
  `kafka.haproxyMap` to configure the strategy.
src/main/java/de/juplo/kafka/chat/backend/ChatBackendProperties.java diff | blob | history
src/main/java/de/juplo/kafka/chat/backend/implementation/haproxy/HaproxyShardingPublisherStrategy.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.