Imports github.com/Shopify/sarama github.com/bsm/sarama-cluster github.com/pkg/errors github.com/segmentio/kafka-go github.com/segmentio/kafka-go/sasl/plain go.uber.org/zap Standard library imports context core/common/log core/config fmt sync time
Go to main page