Avoid sharing the socket in forked process

karafka · Feb 16, 2020 · 3e5331a · 3e5331a
1 parent 0dd1a0d
commit 3e5331a
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/spec/rdkafka/producer_spec.rb b/spec/rdkafka/producer_spec.rb
@@ -292,6 +292,9 @@
     fork do
       reader.close
 
+      # Avoids sharing the socket between processes.
+      producer = rdkafka_config.producer
+
       handle = producer.produce(
         topic:   "produce_test_topic",
         payload: "payload-forked",
@@ -307,7 +310,7 @@
 
       writer.write(report_json)
       writer.close
-      exit!
+      producer.close
     end
 
     writer.close