shopify-sarama-v1

package main import ( "fmt" "gopkg.in/Shopify/sarama.v1" ) func main() { config := sarama.NewConfig() producer, err := sarama.NewSyncProducer([]string{"localhost:9092"}, config) if err != nil { panic(err) } defer producer.Close() msg := &sarama.ProducerMessage{Topic: "test", Value: sarama.StringEncoder("hello")} partition, offset, err := producer.SendMessage(msg) if err != nil { panic(err) } fmt.Printf("Message sent to partition %d at offset %d\n", partition, offset) }