kq

Imports

• github.com/segmentio/kafka-go
• github.com/segmentio/kafka-go/gzip
• github.com/segmentio/kafka-go/lz4
• github.com/segmentio/kafka-go/sasl
• github.com/segmentio/kafka-go/sasl/plain
• github.com/segmentio/kafka-go/sasl/scram
• github.com/segmentio/kafka-go/snappy
• github.com/zeromicro/go-zero/core/executors
• github.com/zeromicro/go-zero/core/logx
• github.com/zeromicro/go-zero/core/queue
• github.com/zeromicro/go-zero/core/service
• github.com/zeromicro/go-zero/core/stat
• github.com/zeromicro/go-zero/core/threading
• github.com/zeromicro/go-zero/core/timex

Standard library imports

• context
• crypto/tls
• io
• log
• strconv
• time