lockmanager uses 1 partition in a message queue

NucleoTeam · Jan 24, 2024 · 750068b · 750068b
1 parent 62c8468
commit 750068b
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/build.gradle b/build.gradle
@@ -6,7 +6,7 @@ plugins {
 }
 
 group = 'com.nucleodb'
-version = '1.15.1'
+version = '1.15.2'
 
 repositories {
     mavenCentral()

diff --git a/src/main/java/com/nucleodb/library/database/lock/LockConfig.java b/src/main/java/com/nucleodb/library/database/lock/LockConfig.java
@@ -10,7 +10,10 @@
 public class LockConfig implements Serializable {
   private static final long serialVersionUID = 1;
   MQSConfiguration mqsConfiguration = new KafkaConfiguration();
-  Map<String, Object> settingsMap = new TreeMap<>();
+  Map<String, Object> settingsMap = new TreeMap<>(){{
+    put("partitions", 1);
+    put("replicas", 3);
+  }};
   String topic = "locks";
 
   public LockConfig() {