Make Pulsar producer and schema volatile

vectorize-io · Apr 1, 2024 · 5badc7e · 5badc7e
1 parent 8b7b710
commit 5badc7e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...time/src/main/java/ai/langstream/pulsar/runner/PulsarTopicConnectionsRuntimeProvider.java b/...time/src/main/java/ai/langstream/pulsar/runner/PulsarTopicConnectionsRuntimeProvider.java
@@ -662,8 +662,8 @@ private class PulsarTopicProducer<K> implements TopicProducer {
             private final Map<String, Object> configuration;
             private final AtomicLong totalIn = new AtomicLong();
             String topic;
-            Producer<K> producer;
-            Schema<K> schema;
+            volatile Producer<K> producer;
+            volatile Schema<K> schema;
 
             private final Object lock = new Object();