kafka

type Config struct {
	// Bootstrap of Kafka cluster. Required.
	Bootstrap []string
	// Version of Kafka
	Version string
	// ServiceName name of service which is implementing health check
	ServiceName string
	// Timeout of a cycle of produce and consume
	Timeout time.Duration
	// CustomTopicName optional custom topic name
	CustomTopicName string
}

type Consumer interface {
	AddClaimer(string, MessageClaimer)
	AddSetupHook(hook Hook)
	AddCleanupHook(hook Hook)
}

type Hook func(session sarama.ConsumerGroupSession)

type MessageClaimer func(*sarama.ConsumerMessage) bool

type Server interface {
	Listen(wg *sync.WaitGroup, close <-chan struct{})
	Close() error
	GetConsumer() sarama.ConsumerGroup
}