For some reason, there can be timeouts in the main loop when waiting for tasks that are meant for the realnet. The corresponding line in the code is the following:
logger.info(f"Checking for consumer message in main loop for realnet...")
message = kafka_client.poll(consumer, config.sync_interval)
if message is None:
logger.error(f"Timeout while waiting for task for realnet")
kafka_client.close()
exit(1)
I have the feeling that this timeout is not really necessary, since it should not be an issue if the realnet does not get messages for a timeperiod. Maybe keep this on record if issues arise in the future.
For some reason, there can be timeouts in the main loop when waiting for tasks that are meant for the realnet. The corresponding line in the code is the following:
I have the feeling that this timeout is not really necessary, since it should not be an issue if the realnet does not get messages for a timeperiod. Maybe keep this on record if issues arise in the future.