fix: synchronizing writes to localcommand file (confluentinc#8406)

mjsax · Nov 23, 2021 · ed50b05 · ed50b05
1 parent 5dd4013
commit ed50b05
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/LocalCommandsFile.java b/ksqldb-rest-app/src/main/java/io/confluent/ksql/rest/server/LocalCommandsFile.java
@@ -59,7 +59,7 @@ public static LocalCommandsFile createWriteable(final File file) {
     return new LocalCommandsFile(file, true);
   }
 
-  public void write(final LocalCommand localCommand) throws IOException {
+  public synchronized void write(final LocalCommand localCommand) throws IOException {
     if (writer == null) {
       throw new IOException("Write permission denied.");
     }
@@ -80,7 +80,7 @@ public List<LocalCommand> readRecords() throws IOException {
   }
 
   @Override
-  public void close() throws IOException {
+  public synchronized void close() throws IOException {
     if (writer != null) {
       writer.close();
     }