sarama

type Handler struct {
	Producer
	// contains filtered or unexported fields
}

type Logger interface {
	Infof(string, ...interface{})
	Errorf(string, ...interface{})
}

type OptionFunc func(*Handler) error

type Producer interface {
	Close() error
	SendWithKey(topic string, key, value []byte) error
	SendMessages(msgs []*sarama.ProducerMessage) error
}

type ProducerMessage struct{}

type SimpleAsyncProducer struct {
	sarama.AsyncProducer
	ProducerMessage
}

type SimpleSyncProducer struct {
	sarama.SyncProducer
	ProducerMessage
}