SyncProducer in Go

Posted by GoDoc
Public (Editable by Users)

This example shows the basic usage pattern of the SyncProducer.

Go
Edit
package main

import "log"

func main() {
    producer, err := NewSyncProducer([]string{"localhost:9092"}, nil)
    if err != nil {
        log.Fatalln(err)
    }
    defer func() {
        if err := producer.Close(); err != nil {
            log.Fatalln(err)
        }
    }()

    msg := &ProducerMessage{Topic: "my_topic", Value: StringEncoder("testing 123")}
    partition, offset, err := producer.SendMessage(msg)
    if err != nil {
        log.Printf("FAILED to send message: %s\n", err)
    } else {
        log.Printf("> message sent to partition %d at offset %d\n", partition, offset)
    }
}