- consumer.seek(tp, unseenOffset);
- chatRoomMaps[partition]
- .values()
- .stream()
- handlers[partition] = new ChatRoomLoadingMessageHandlingStrategy(tp, currentOffset, unseenOffset);
+ // TODO: reuse! Nicht immer alles neu laden, sondern erst ab offsets[partition]!
+ consumer.seek(topicPartition, unseenOffset);
+ chatHomeLoaders[partition] = new ChatHomeLoader(
+ producer,
+ currentOffset,
+ zoneId);