kafka

type Config struct {
	// Brokers required, kafka brokers separated by comma.
	Brokers string

	// Group required, kafka consumer group.
	Group string

	// SaramaConfig required, kafka sarama config.
	SaramaConfig *sarama.Config

	// Name optional, kafka server name to be exposed.
	Name string
}

type Consumer struct {
	// contains filtered or unexported fields
}

type HandlerFunc func(ctx context.Context, message *sarama.ConsumerMessage) error

type IServer interface {
	Run() error
	Shutdown() error
}

type Option interface {
	Apply(o *options)
}