context.md

brew info librdkafka

librdkafka: stable 1.0.0 (bottled), HEAD
The Apache Kafka C/C++ library
https://github.com/edenhill/librdkafka
/usr/local/Cellar/librdkafka/1.0.0 (16 files, 2.6MB) *
  Poured from bottle on 2019-04-04 at 11:15:56
From: https://github.com/Homebrew/homebrew-core/blob/master/Formula/librdkafka.rb
==> Dependencies
Build: pkg-config ✔
Required: lz4 ✘, lzlib ✔, openssl ✔, zstd ✘
==> Options
--HEAD
        Install HEAD version
==> Analytics
install: 5,466 (30 days), 11,432 (90 days), 37,255 (365 days)
install_on_request: 2,429 (30 days), 5,371 (90 days), 17,760 (365 days)
build_error: 0 (30 days)

go.mod

module git.drillinginfo.com/brian-sorahan/kurl

require (
        github.com/confluentinc/confluent-kafka-go v1.0.0
        github.com/pkg/errors v0.8.1
)

main.go

package main

import (
        "context"
        "flag"
        "fmt"
        "os"

        "github.com/confluentinc/confluent-kafka-go/kafka"
        "github.com/pkg/errors"
)

func main() {
        var (
                brokers string
        )
        flag.StringVar(&brokers, "b", "", "Kafka brokers.")
        flag.Parse()

        client, err := kafka.NewAdminClient(&kafka.ConfigMap{
                "bootstrap.servers": brokers,
        })
        die(errors.Wrap(err, "creating admin client"))

        ctx := context.Background()

        results, err := client.DescribeConfigs(ctx, []kafka.ConfigResource{
                {
                        Name: "dp-mfg-pdenprod-api14",
                        Type: kafka.ResourceGroup,
                },
        })
        die(errors.Wrap(err, "describing consumer group"))

        for _, result := range results {
                fmt.Printf("%s\n", result)
        }
}

func die(err error) {
        if err == nil {
                return
        }
        fmt.Fprintln(os.Stderr, err.Error())
        os.Exit(1)
}

output

%3|1556721063.615|PROTOERR|rdkafka#producer-1| [thrd:main]: 10.25.11.7:9092/107: Protocol parse failure at 107/107 (rd_kafka_DescribeConfigsResponse_parse:2641) (incorrect broker.version.fallback?)
%3|1556721063.615|PROTOERR|rdkafka#producer-1| [thrd:main]: 10.25.11.7:9092/107: Broker returned ConfigResource 0,dp-mfg-pdenprod-api14 that was not included in the original request
kurl(84397,0x70000ba14000) malloc: *** error for object 0x7503050: pointer being freed was not allocated
*** set a breakpoint in malloc_error_break to debug