Tutorial을 위한 Produver 구현

• 코드

package main

import (
	"context"
	"fmt"
	"log"
	"os"
	"time"

	_ "github.com/go-sql-driver/mysql"
	"github.com/segmentio/kafka-go"
)

func main() {
	fmt.Println("MYSQLCS_USER_NAME: ", os.Getenv("MYSQLCS_USER_NAME"))

	kafkaServer := "192.168.20.121:9092"
	conn, err := kafka.DialLeader(context.Background(), "tcp", kafkaServer, "topic_test", 0)
	if err != nil {
		log.Fatal("failed to dial leader: ", err)
	}

	conn.SetWriteDeadline(time.Now().Add(10 * time.Second))
	conn.WriteMessages(kafka.Message{Value: []byte("hello kafka again")})

	// _, err = conn.WriteMessages(
	// 	kafka.Message{Value: []byte("one!")},
	// 	kafka.Message{Value: []byte("two!")},
	// 	kafka.Message{Value: []byte("three!")},
	// )
	// if err != nil {
	// 	log.Fatal("failed to write messages:", err)
	// }

	// if err := conn.Close(); err != nil {
	// 	log.Fatal("failed to close writer:", err)
	// }
}