Imports github.com/confluentinc/confluent-kafka-go/kafka github.com/pkg/errors gopkg.in/yaml.v2 Imports in module “gitlab.com/gtsh77-shared/kafka-mq-go” gitlab.com/gtsh77-shared/kafka-mq-go/pkg/kafka gitlab.com/gtsh77-shared/kafka-mq-go/pkg/logging gitlab.com/gtsh77-shared/kafka-mq-go/queue/internal Standard library imports context flag io io/ioutil sync sync/atomic time