Junior — Middle
Použil si Kafka Producer vo svojich projektoch?
sobes.tech AI
Odpoveď od AI
Áno, používal som Kafka Producer vo svojich projektoch v Go na odosielanie správ do Kafka tém. Zvyčajne som používal knižnicu segmentio/kafka-go, ktorá umožňuje jednoduchú a efektívnu integráciu s Kafka. Príklad vytvorenia a odoslania správy:
package main
import (
"context"
"log"
"github.com/segmentio/kafka-go"
)
func main() {
writer := kafka.NewWriter(kafka.WriterConfig{
Brokers: []string{"localhost:9092"},
Topic: "example-topic",
})
defer writer.Close()
err := writer.WriteMessages(context.Background(),
kafka.Message{
Key: []byte("Key-A"),
Value: []byte("Hello Kafka from Go!"),
},
)
if err != nil {
log.Fatal("Chyba pri písaní správ:", err)
}
}
Tento prístup umožňuje asynchrónne odosielanie dát a budovanie škálovateľných systémov výmeny správ.