forgot to flush

2026-05-13 23:45:26 +00:00 · 2018-10-09 14:08:02 -04:00
parent 5827d8b137
commit d4cf4a7e5f
1 changed files with 2 additions and 0 deletions
@@ -30,6 +30,7 @@ class KafkaClient(object):

        for report in aggregate_reports:
            self.producer.send(aggregate_topic, report)
+            self.producer.flush()


  def save_forensic_reports_to_kafka(self, forensic_reports, forensic_topic):
@@ -49,3 +50,4 @@ class KafkaClient(object):

            for report in forensic_reports:
                self.producer.send(forensic_topic, report)
+                self.producer.flush()