From: Kai Moritz <kai@juplo.de>
Date: Fri, 24 Feb 2023 10:59:38 +0000 (+0100)
Subject: WIP:compiles
X-Git-Tag: wip-sharding~3
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=aae047568e9816fdb8ca9129ecc9a371fc9bc9ce;p=demos%2Fkafka%2Fchat

WIP:compiles
---

diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/inmemory/InMemoryServicesConfiguration.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/inmemory/InMemoryServicesConfiguration.java
index 82f6da5b..cb1a0703 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/persistence/inmemory/InMemoryServicesConfiguration.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/inmemory/InMemoryServicesConfiguration.java
@@ -11,7 +11,6 @@ import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
 import java.time.Clock;
-import java.util.UUID;
 
 
 @ConditionalOnProperty(
@@ -45,7 +44,7 @@ public class InMemoryServicesConfiguration
       case none:
         numShards = 1;
         ownedShards = new int[] { 0 };
-        shardingStrategy = (UUID id) -> 0;
+        shardingStrategy = id -> 0;
         break;
       case kafkalike:
         numShards = properties.getInmemory().getNumShards();