sarama.go

package main

import (
	"fmt"
	"log"
	"os"

	"github.com/Shopify/sarama"
)

func main() {
	sarama.Logger = log.New(os.Stdout, "sarama: ", log.Lshortfile)
	pubClient, err := sarama.NewClient("pub", []string{"192.168.59.103:9092"},
		sarama.NewClientConfig())
	if err != nil {
		panic(err)
	}
	subClient, err := sarama.NewClient("sub", []string{"192.168.59.103:9092"},
		sarama.NewClientConfig())
	if err != nil {
		panic(err)
	}

	pub, err := sarama.NewProducer(pubClient, nil)
	if err != nil {
		panic(err)
	}
	consumerConfig := sarama.NewConsumerConfig()
	consumerConfig.OffsetMethod = sarama.OffsetMethodNewest // Only read new messages
	consumerConfig.DefaultFetchSize = 10 * 1024 * 1024
	sub, err := sarama.NewConsumer(subClient, "test", 0, "test", consumerConfig)
	if err != nil {
		panic(err)
	}
	pub.Input() <- &sarama.MessageToSend{Topic: "test", Key: nil, Value: sarama.StringEncoder("testing 123")}
	event := <-sub.Events()
	fmt.Println(string(event.Value))
}