Commit 0f6d068c authored by Hines, Jesse's avatar Hines, Jesse
Browse files

Fix kafka loop 

Needs to call .poll
parent 3877514e

simulation_server/simulation/main.py

+1 −0
Original line number Diff line number Diff line
@@ -64,6 +64,7 @@ def write_sim_to_kafka(sim: Sim): 
            # kafka_producer does its own buffering of output so we don't need to worry about batching

            for topic, messages in data.items():

                for message in messages:

                    kafka_producer.poll(0)

                    kafka_producer.produce(topic, message)

    finally:

        kafka_producer.flush()