Spaces:
Runtime error
Runtime error
Update app.py
#1
by
dad1909
- opened
app.py
CHANGED
|
@@ -24,7 +24,6 @@ if __name__ == "__main__":
|
|
| 24 |
for config in consumers_config:
|
| 25 |
consumer_thread = start_kafka_consumer_thread(config["group_id"], config["topic"])
|
| 26 |
consumer_threads.append(consumer_thread)
|
| 27 |
-
|
| 28 |
try:
|
| 29 |
while True:
|
| 30 |
time.sleep(1)
|
|
|
|
| 24 |
for config in consumers_config:
|
| 25 |
consumer_thread = start_kafka_consumer_thread(config["group_id"], config["topic"])
|
| 26 |
consumer_threads.append(consumer_thread)
|
|
|
|
| 27 |
try:
|
| 28 |
while True:
|
| 29 |
time.sleep(1)
|