From 750068b730560829f83fa0fd072616c81ea6ab6f Mon Sep 17 00:00:00 2001 From: Nathaniel Date: Tue, 23 Jan 2024 18:36:35 -0700 Subject: [PATCH] lockmanager uses 1 partition in a message queue --- build.gradle | 2 +- .../java/com/nucleodb/library/database/lock/LockConfig.java | 5 ++++- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/build.gradle b/build.gradle index 9fa159f..f9e8864 100644 --- 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 index c3cf7d8..50a0e31 100644 --- 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 settingsMap = new TreeMap<>(); + Map settingsMap = new TreeMap<>(){{ + put("partitions", 1); + put("replicas", 3); + }}; String topic = "locks"; public LockConfig() {