Kafka consumer is used for the internal testing purpose, we add more logs into it, to make the daily debug life easier.