consumer.go

package main

import (
    "context"
    "github.com/segmentio/kafka-go"
)

func consume(ctx context.Context) {
    dialer := saslScramDialer()

    r := kafka.NewReader(kafka.ReaderConfig{
        Brokers: brokers,
        Topic:   topic2,
        GroupID: group,
        Logger:  kafka.LoggerFunc(log.Debugf),
        Dialer:  dialer,
    })
    for {
        msg, err := r.ReadMessage(ctx)
        if err != nil {
            log.Panicf("%v could not read message: %v", getHostname(), err.Error())
        }
        log.Debugf("%v received message: %v", getHostname(), string(msg.Value))
    }
}