¿Qué biblioteca utilizaste para interactuar con Kafka?

Para interactuar con Kafka en el lenguaje Go, a menudo se utiliza la biblioteca Shopify/sarama. Es un cliente de Kafka popular y bien soportado para Go, que proporciona un conjunto completo de funciones para productores y consumidores.

Ejemplo de un productor simple usando sarama:

package main

import (
    "log"
    "github.com/Shopify/sarama"
)

func main() {
    producer, err := sarama.NewSyncProducer([]string{"localhost:9092"}, nil)
    if err != nil {
        log.Fatal("Error al crear el productor", err)
    }
    defer producer.Close()

    msg := &sarama.ProducerMessage{
        Topic: "test_topic",
        Value: sarama.StringEncoder("Hola Kafka"),
    }

    partition, offset, err := producer.SendMessage(msg)
    if err != nil {
        log.Fatal("Error al enviar el mensaje", err)
    }

    log.Printf("Mensaje enviado a la partición %d en el offset %d", partition, offset)
}

Además de sarama, existen otras bibliotecas, como segmentio/kafka-go, pero sarama es una de las más populares.