Hugging Face's logo

Spaces:
AppliedInfo
/
turner_ml
Sleeping

App Files Community
aamirtaymoor commited on
Commit
632be18
·
verified ·
1 Parent(s): 6ee636d

Update kafka_consumer.py

Browse files
Files changed (1) hide show
  1. kafka_consumer.py +3 -2
kafka_consumer.py CHANGED
@@ -36,5 +36,6 @@ def kafka_consumer():
36
  consumer.close()
37
 
38
  if __name__ == "__main__":
39
- kafka_consumer()
40
- print("Restarting Kafka consumer...")
 
 
36
  consumer.close()
37
 
38
  if __name__ == "__main__":
39
+ while True:
40
+ kafka_consumer()
41
+ print("Restarting Kafka consumer...")