Reputation: 411
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