Testing github.com/segmentio/kafka-go CreateTopics method.

mktopic.go

package main

import (
	"fmt"
	"io"
	"log"
	"os"

	"github.com/pkg/errors"
	sk "github.com/segmentio/kafka-go"
)

func main() {
	if len(os.Args) < 2 {
		fmt.Fprintln(os.Stderr, errors.Errorf("expected usage: %s BROKER", os.Args[0]).Error())
	}
	conn, err := sk.Dial("tcp", os.Args[1])
	if err != nil {
		log.Fatal(errors.Wrap(err, "connecting to broker"))
	}
	err = conn.CreateTopics(sk.TopicConfig{
		Topic: "topic-name-redacted",
	})
	if ske, ok := err.(sk.Error); ok {
		fmt.Printf("error description   %s\n", ske.Description())
		fmt.Printf("error title         %s\n", ske.Title())
		fmt.Printf("error is temporary: %#v\n", ske.Temporary())
		fmt.Printf("error is timeout:   %#v\n", ske.Timeout())
	}
	if err == io.EOF {
		fmt.Printf("got io.EOF\n")
	}
	if err := errors.Wrap(err, "creating topics"); err != nil {
		log.Fatal(err)
	}
}