Update
This commit is contained in:
parent
c59d406493
commit
d866038826
@ -89,6 +89,7 @@ class KafkaConsumerThread(threading.Thread):
|
||||
)
|
||||
except:
|
||||
self.stop()
|
||||
return
|
||||
|
||||
logger.info("Kafka Consumer started")
|
||||
|
||||
|
||||
Loading…
Reference in New Issue
Block a user