INNER CODE UNIT · Go

createTopic

qpoint-io/qtap · apps/kafka/go/main.go:77

func createTopic(broker, topic string) {
	conn, err := kafka.Dial("tcp", broker)
	if err != nil {
		fmt.Printf("[Go] Failed to connect to broker: %v\n", err)
		os.Exit(1)
	}
	defer conn.Close()

	controller, err := conn.Controller()
	if err != nil {
		fmt.Printf("[Go] Failed to get controller: %v\n", err)
		os.Exit(1)
	}

	controllerConn, err := kafka.Dial("tcp", fmt.Sprintf("%s:%d", controller.Host, controller.Port))
	if err != nil {
		fmt.Printf("[Go] Failed to connect to controller: %v\n", err)
		os.Exit(1)

View source record →