Group Consumer

package main

import (
	"flag"
	"fmt"

	"github.com/childe/healer"
	"github.com/golang/glog"
)

func main() {
	flag.Parse()

	configMap := make(map[string]interface{})
	configMap["bootstrap.servers"] = "127.0.0.1:9092,127.0.0.1:9093"
	configMap["group.id"] = "mygroup"

	config, err := healer.GetConsumerConfig(configMap)
	if err != nil {
		glog.Errorf("could not create consumer config: %s", err)
	}

	c, err := healer.NewGroupConsumer("TOPICNAME", config)
	if err != nil {
		glog.Errorf("could not create GroupConsumer: %s", err)
	}
	defer c.Close()

	messages, err := c.Consume(nil)
	if err != nil {
		glog.Fatalf("failed to consume: %s", err)
	}

	for {
		message := <-messages
		fmt.Printf("%s:%d:%d:%s\n", message.TopicName, message.PartitionID, message.Message.Offset, message.Message.Value)
	}
}

Producer

package main

import (
	"flag"

	"github.com/childe/healer"
	"github.com/golang/glog"
)

func main() {
	flag.Parse()

	configMap := make(map[string]interface{})
	configMap["bootstrap.servers"] = "127.0.0.1:9092,127.0.0.1:9093"
	config, err := healer.GetProducerConfig(configMap)

	if err != nil {
		glog.Errorf("coult not create producer config: %s", err)
		return
	}

	producer := healer.NewProducer("TOPICNAME", config)
	if producer == nil {
		glog.Error("could not create producer")
	}
	defer producer.Close()

	key := []byte("")
	msg := []byte("")
	producer.AddMessage(key, msg)
	// producer.AddMessage(nil, msg)
}

Console Consumer

Simple Consumer

Group Consumer (assign certain parititons, do not need join group)