Golang Kafka Consumer with SASL Auth

kafka_sasl_consumer.go

package main

import (
	"context"
	"fmt"
	"log"
	"strings"

  // An EOF error always occurs when using the IBM/sarama, but segmentio/kafka-go works fine
	"github.com/segmentio/kafka-go"
	"github.com/segmentio/kafka-go/sasl/scram"
)

var (
	brokers       = ""
	topic         = ""
	groupId       = ""
	scramUsername = ""
	scramPassword = ""
)

func main() {
	saslMechanism, err := scram.Mechanism(scram.SHA512, scramUsername, scramPassword)
	if err != nil {
		log.Fatal(err)
	}

	reader := kafka.NewReader(kafka.ReaderConfig{
		Brokers:  strings.Split(brokers, ","),
		GroupID:  groupId,
		Topic:    topic,
		MinBytes: 10e3, // 10KB
		MaxBytes: 10e6, // 10MB
		Dialer: &kafka.Dialer{
			SASLMechanism: saslMechanism,
		},
	})
	defer reader.Close()

	fmt.Println("start consuming ... !!")
	for {
		m, err := reader.ReadMessage(context.Background())
		if err != nil {
			log.Fatalln(err)
		}
		fmt.Printf("message at topic:%v partition:%v offset:%v	%s = %s\n", m.Topic, m.Partition, m.Offset, string(m.Key), string(m.Value))
	}
}