analytic

type AnalyserServices interface {
	Start() error
	Close()
	SetUpConfig() cluster.Config
	SetUpClient(config *sarama.Config) (sarama.Client, error)
	NewClusterConsumer(groupID string, topic string) (*cluster.Consumer, error)
}