Junior — Middle
Já usaste Kafka Producer nos teus projetos?
sobes.tech IA
Resposta da IA
Sim, utilizei Kafka Producer nos meus projetos em Go para enviar mensagens para tópicos Kafka. Normalmente, usava a biblioteca segmentio/kafka-go, que permite uma integração simples e eficiente com Kafka. Exemplo de criação e envio de uma mensagem:
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("failed to write messages:", err)
}
}
Esta abordagem permite enviar dados de forma assíncrona e construir sistemas de troca de mensagens escaláveis.