Imports gitee.com/gomods/config gitee.com/gomods/logger github.com/confluentinc/confluent-kafka-go/kafka github.com/go-redis/redis/v8 github.com/spf13/cast github.com/streadway/amqp Standard library imports context encoding/json errors fmt io/ioutil runtime/debug strings sync sync/atomic time