[BUG] The kafka.NewMConsumerGroup code fails to connect to the Kafka cluster when SASL is configured in Kafka, as the SASL settings are not set in the code.

[sdzhu]

func NewMConsumerGroup(consumerConfig *MConsumerGroupConfig, topics, addrs []string, groupID string) *MConsumerGroup {
config := sarama.NewConfig()
config.Version = consumerConfig.KafkaVersion
config.Consumer.Offsets.Initial = consumerConfig.OffsetsInitial
config.Consumer.Return.Errors = consumerConfig.IsReturnErr
fmt.Println("init address is ", addrs, "topics is ", topics)

      //这里应该要向consumer.go一样，要加入SASL的配置代码


  consumerGroup, err := sarama.NewConsumerGroup(addrs, groupID, config)
  if err != nil {
	  panic(err.Error())
  }
  return &MConsumerGroup{
	  consumerGroup,
	  groupID,
	  topics,
  }

}

[kubbot]

This issue is stale because it has been open 60 days with no activity. Remove stale label or comment or this will be closed in 7 days.

[kubbot]

This issue is stale because it has been open 60 days with no activity. Remove stale label or comment or this will be closed in 7 days.

[kubbot]

This issue was closed because it has been stalled for 7 days with no activity.