sgallizia

My colleague fixed the issue changing how the consumer group is created: ```go func newConsumerGroup(cnsCfg *sarama.Config) (sarama.ConsumerGroup, error) { cnsCfg.Metadata.RefreshFrequency = 0 * time.Second client, err := sarama.NewClient([]string{config.Value.Stream.Broker}, cnsCfg) if...