snippet1.go

func main() {
	kafkaBroker := "foo:9092"
	p, err := kafka.NewProducer(&kafka.ConfigMap{"bootstrap.servers": kafkaBroker})
	if err != nil {
		fmt.Println("producer creation failed ", err.Error())
		return
	}

	topic := "bar"
	partition := kafka.TopicPartition{Topic: &topic, Partition: kafka.PartitionAny}
	msg := &kafka.Message{TopicPartition: partition, Key: []byte("hello"), Value: []byte("world")}
	err = p.Produce(msg, nil)
	fmt.Println("done...")
}