demos/kafka/chat
2024-03-04 Kai Moritztest: HandoverIT-POC - fix for the blocking wait for...
2024-03-03 Kai Moritztest: HandoverIT-POC - working fix: using `delayElements()`
2024-03-03 Kai Moritztest: HandoverIT-POC - not working fix: using `delay()`
2024-03-03 Kai Moritztest: HandoverIT-POC - FIX: `take(n)`, does end the...
2024-03-03 Kai Moritztest: HanoverIT-POC - Executing the Flux/Mono asynchrou...
2024-03-03 Kai Moritztest: HandoverIT-POC - Listener/Writer remember receive...
2024-03-03 Kai Moritztest: HandoverIT-POC - Refactored listening into class...
2024-03-03 Kai Moritztest: HandoverIT-POC - Refactored `TestWriter` to use...
2024-03-01 Kai Moritztest: HandoverIT-POC - Each `TestWriter` writes only...
2024-03-01 Kai Moritztest: HandoverIT-POC - Refactored / Cleaned up
2024-03-01 Kai Moritztest: HandoverIT-POC - Renamed `TestClient` to `TestWri...
2024-03-01 Kai Moritztest: HandoverIT-POC - Renamed `TestClient` to `TestWri...
2024-02-28 Kai Moritztest: HandoverIT-POC - Fixed illegal client-naming...
2024-02-28 Kai Moritztest: HandoverIT-POC - Fixed logging of failed client...
2024-02-28 Kai Moritzfix: Fixed `ConcurrentModificationException` when acces...
2024-02-28 Kai Moritzrefactor: Introduced `ChannelMediator`
2024-02-28 Kai Moritztest: HandoverIT-POC - clients are stopped after some...
2024-02-28 Kai Moritztest: HandoverIT-POC - running multiple clients in...
2024-02-27 Kai Moritztest: HandoverIT-POC - added a delay to the sending...
2024-02-27 Kai Moritztest: HandoverIT-POC - remodeled sending into a for...
2024-02-27 Kai Moritztest: HandoverIT-POC - messages are written to 23 chat...
2024-02-27 Kai Moritztest: HandoverIT-POC - splitted up code into smaller...
2024-02-27 Kai Moritztest: HandoverIT-POC - splitted up code into smaller...
2024-02-27 Kai Moritztest: HandoverIT-POC - Moved general container-defs...
2024-02-27 Kai Moritztest: HandoverIT-POC - setup without static containers
2024-02-27 Kai Moritztest: HandoverIT-POC - first working setup for the...
2024-02-26 Kai Moritzfix: Errors during shard-publishing should not kill...
2024-02-26 Kai Moritzfix: Sensible value for sink-buffer
2024-02-26 Kai Moritzfeat: Made polling-interval for Kafka configurable
2024-02-26 Kai Moritzfix: The number of chards is the number of partitions...
2024-02-23 Kai Moritzfix: Disabled mongodb-autoconfig, if mongodb is not...
2024-02-22 Kai Moritzfeat: Switched to `spring-boot-starter-data-mongodb...
2024-02-22 Kai Moritzfeat: Added logging for io.projectreactor to `MongoDbSt...
2024-02-22 Kai Moritzrefactor: DRY for logging-category from io.projectreactor
2024-02-22 Kai Moritzfeat: Added counting of restored instances
2024-02-22 Kai Moritztest: `StorageStrategy`-IT are restoring instead of...
2024-02-22 Kai Moritzfix: GREEN - Fixed the restore-mechanism
2024-02-22 Kai Moritzrefactor: RED - Refined success/error-handling for...
2024-02-22 Kai Moritztest: Simplified the integration-tests for `StorageStra...
2024-02-22 Kai Moritztest: Simplified `InMemoryWithMongoDbStorageIT`
2024-02-22 Kai Moritztest: Added IT for `ChatRoomRepository` and `MessageRep...
2024-02-22 Kai Moritztest: Simplified & Unified the Kafka-tests
2024-02-22 Kai Moritztest: Simplified `ChatHomeServiceTest`
2024-02-22 Kai Moritztest: Simplified & unified test-setup for ``ChatHomeSer...
2024-02-20 Kai Moritzrefactor: Cleaned up code
2024-02-20 Kai Moritzfeat: Introduced counting of stored instances in `Stora...
2024-02-20 Kai Moritzfeat: Introduced config-parameters for the `io.projectr...
2024-02-20 Kai Moritzrefactor: Set logging-level for io.projectreactor to...
2024-02-20 Kai Moritzrefactor: Refined stream-definition in `StorageStrategy...
2024-02-20 Kai Moritzrefactor: Refined return-type of `StorageStrategy#write`
2024-02-20 Kai Moritzrefactor: One stream -> using `flatMap` instead of...
2024-02-20 Kai Moritzrefactor: Moved succes/error-logging to outer stream...
2024-02-20 Kai Moritzrefactor: Simplified `StorageStrategy`
2024-02-20 Kai Moritzrefactor: Moved extracted the `subscribe()`-call from...
2024-02-20 Kai Moritzrefactor: Extracted subscription into a separate method...
2024-02-20 Kai Moritztest: Added missing JSR-310 module to not Spring-Boot...
2024-02-20 Kai Moritzfeat: Added log message for disabled storage
2024-02-20 Kai Moritzfix: Without `@DirtiesContext` the app is not teared...
2024-02-20 Kai Moritztest: Introduced integration-tests for `NoStorageStorag...
2024-02-20 Kai Moritztest: Introduced integration-tests for `NoStorageStorag...
2024-02-20 Kai Moritzrefactor: Extracted annonymous class into `NoStorageSto...
2024-02-20 Kai Moritzrefactor: Extracted annonymous class into `NoStorageSto...
2024-02-20 Kai Moritzrefactor: Added success- and failure-callbacks for...
2024-02-20 Kai Moritzrefactor: Added success- and failure-callbacks to ...
2024-02-20 Kai Moritzrefactor: `KafkaServicesApplicationRunner` aufgerÀumt
2024-02-20 Kai Moritzfix: Config-ITs do not fail, if run multiple times
2024-02-20 Kai Moritzfix: Removed manual version-management for testcontaine...
2024-02-20 Kai Moritzfeat: Upgraded Spring Boot 3.1.3 -> 3.2.2
2024-02-20 Kai Moritzfix: `getChatRoomInfo()` thrwos `LoadInProgressExceptio...
2024-02-20 Kai Moritzrefactor: compute `loadInProgress` on offset-change
2024-02-20 Kai Moritzrefactor: separated message- and record- (aka offset...
2024-02-20 Kai Moritzrefactor: Renamed method in `InfoChannel` according...
2024-02-20 Kai Moritzrefactor: Made only locally used method in `KafkaChatHo...
2024-02-20 Kai Moritzfeat: The position of the last seen messages is stored...
2024-02-20 Kai Moritzfix: The actual position has to be requested from the...
2024-02-20 Kai Moritzrefactor: Added logging of loaded messages
2024-02-20 Kai Moritzrefactor: Refined success/error-handling when publishin...
2024-02-20 Kai Moritzfeat: Implemented `HaproxyShardingPublisherStrategy`
2024-02-20 Kai Moritzfeat: Introduced interface `ShardingPublisherStrategy`
2024-02-20 Kai Moritzfeat: Introduced a configurable instance-id
2024-02-20 Kai Moritzfix: `ConsumerTaskRunner` waits until the data-loading...
2024-02-20 Kai Moritzfeat: Introduced events that are send, if a shard is...
2024-02-20 Kai Moritzfix: `metadata` is never `null`
2024-02-20 Kai Moritzrefactor: DRY for computation of new `ChatRoomData...
2024-02-20 Kai Moritzfix: GREEN - `DataChannel` creates entries for existent...
2024-02-20 Kai Moritztest: RED - Putting a message in a newly created chat...
2024-02-20 Kai Moritzrefactor: Splitted test in `AbstractConfigurationIT...
2024-02-20 Kai Moritzrefactor: Moved common test-code into helper-class...
2024-02-20 Kai Moritzrefactor: Moved common test-code into helper-class...
2024-02-20 Kai Moritzrefactor: Extracted interface `WorkAssignor` into separ...
2024-02-20 Kai Moritzrefactor: Separated channels for data and info -- Refac...
2024-02-20 Kai Moritzrefactor: Separated channels for data and info -- Moved...
2024-02-20 Kai Moritzrefactor: Introduced `ConsumerTaskExecutor` -- Aligned...
2024-02-20 Kai Moritzrefactor: Introduced `ConsumerTaskExecutor` -- Copied...
2024-02-20 Kai Moritzrefactor: `KafkaChatHomeServiceTest` reuses regular...
2024-02-20 Kai Moritzrefactor: `KafkaServicesApplicationRunner` without...
2024-02-20 Kai Moritzrefactor: Renamed `ChatRoomService` into `ChatMessageSe...
2024-02-20 Kai Moritzrefactor: Renamed `ChatRoomService` into `ChatMessageSe...
2024-02-20 Kai Moritzrefactor: Removed unused methods
2024-02-20 Kai Moritzrefactor: Renamed `persistence` into `implementation...
next