kafkax

type Client interface {
	// Get get kafka client
	Get() sarama.Client

	// Close close kafka client
	Close() error

	// SendMessage send message to kafka
	SendMessage(ctx context.Context, message *sarama.ProducerMessage) error

	// GroupConsume consume kafka group
	GroupConsume(ctx context.Context, group string, topics []string, handler sarama.ConsumerGroupHandler) error
}