diff --git a/python/lsst/ap/association/packageAlerts.py b/python/lsst/ap/association/packageAlerts.py
index b282c8f1..1b49a5bb 100644
--- a/python/lsst/ap/association/packageAlerts.py
+++ b/python/lsst/ap/association/packageAlerts.py
@@ -306,6 +306,7 @@ def run(self,
 
         if self.config.doProduceAlerts:
             self.produceAlerts(alerts, visit, detector)
+            self.producer.close()
 
         if self.config.doWriteAlerts:
             with open(os.path.join(self.config.alertWriteLocation, f"{visit}_{detector}.avro"), "wb") as f: