produce-and-forget.go

func main() {
	kafkaBroker := "localhost:9092"
	p, _ := kafka.NewProducer(&kafka.ConfigMap{"bootstrap.servers": kafkaBroker})

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