ASIF KAIF
ASIF KAIF

Reputation: 411

how to implement kafka in golang using confuentic kafka library

I have windows OS and i want to implement kafka in golang but after installing library it is showing error. whatever methods i am calling using kafka it is undefined.For example methods like NewProducer, Configmap etc are undefined. I am runing zookeer and kafka server using docker.



import (
    "fmt"

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

func main() {
    config := kafka.ConfigMap{"bootstrap.servers": "localhost:9092"}
    producer, err := kafka.NewProducer(&config)
    if err != nil {
        panic(fmt.Sprintf("Failed to create producer: %v", err))
    }
    defer producer.Close()
    topic := "my_topic" // Replace "my_topic" with your actual topic name
p
    for i := 1; i <= 5; i++ {
        message := fmt.Sprintf("Message %d", i)

        err := producer.Produce(&kafka.Message{
            TopicPartition: kafka.TopicPartition{Topic: &topic, Partition: kafka.PartitionAny},
            Value:          []byte(message),
        }, nil)

        if err != nil {
            fmt.Printf("Failed to produce message: %v\n", err)
        } else {
            fmt.Printf("Produced message: %s\n", message)
        }
    }

    producer.Flush(15 * 1000)
}

Upvotes: 1

Views: 392

Answers (0)

Related Questions