A detailed explanation of the basic operations of Golang connecting kafka

bin/ config/

bin/ config/

bin/ --create --topic hello --bootstrap-server Host Name:9092

bin/ --broker-list Host Name:9092 --topic hello

bin/ --bootstrap-server Host Name:9092 --from-beginning --topic hello

bin/ --bootstrap-server Host Name:9092 --partition 0 --offset 1 --topic hello

bin/ --bootstrap-server localhost:9092 --topic hello

// Kafka configurationconst (
	KafkaBroker = "u8sMaster:9092" // Replace with your Kafka Broker address	KafkaTopic  = "k8s-version"          // Kafka theme)

func main() {
	sendMesgKafka()
}

func sendMesgKafka() {
	w := ({
		Brokers:  []string{KafkaBroker},
		Topic:    KafkaTopic,
		Balancer: &{},
	})

	err := ((),
		{
			Key:   []byte("Key-A"),
			Value: []byte("one!"),
		},
		{
			Key:   []byte("Key-B"),
			Value: []byte("two!"),
		},
		{
			Key:   []byte("Key-C"),
			Value: []byte("three!"),
		},
	)

	if err != nil {
		("failed to write messages:", err)
	}

	if err := (); err != nil {
		("failed to close writer:", err)
	}

	("Message sent successfully")

}

// to consume messages
topic := "test"
partition := 0

conn, err := ((), "tcp", "u8sMaster:9092", topic, partition)
if err != nil {
    ("failed to dial leader:", err)
}

(().Add(10*))
batch := (10e3, 1e6) // fetch 10KB min, 1MB max

b := make([]byte, 10e3) // 10KB max per message
for {
    n, err := (b)
    if err != nil {
        break
    }
    (string(b[:n]))
}

if err := (); err != nil {
    ("failed to close batch:", err)
}

if err := (); err != nil {
    ("failed to close connection:", err)
}

func main() {
    conn, err := ("tcp", "u8sMaster:9092")
    if err != nil {
        panic(())
    }
    defer ()
    
    partitions, err := ()
    if err != nil {
        panic(())
    }
    
    m := map[string]struct{}{}
    
    for _, p := range partitions {
        m[] = struct{}{}
    }
    for k := range m {
        (k)
    }
}

func main() {
        conn, err := ((), "tcp", "u9sMaster:9092", "topic2", 0)
        if err != nil {
            panic(())
        }
}

func main() {
    conn, err := ("tcp", "u8sMaster:9092")
    if err != nil {
        panic(())
    }
    defer ()
    controller, err := ()
    if err != nil {
        panic(())
    }
    var connLeader *
    connLeader, err = ("tcp", (, ()))
    if err != nil {
        panic(())
    }
    defer ()
}