async def kafka_read_callback(self, topic, command, params):
order_id = 1
- self.logger.info(
+ self.logger.debug(
"Topic: {} command: {} params: {} order ID: {}".format(
topic, command, params, order_id
)
)
if topic != "admin" and command != "ping":
- self.logger.debug(
+ self.logger.info(
"Task kafka_read receives {} {}: {}".format(topic, command, params)
)
self.consecutive_errors = 0
self.first_start = False
order_id += 1
- self.logger.info(
+ self.logger.debug(
"Consecutive error: {} First start: {}".format(
self.consecutive_errors, self.first_start
)