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)
}
}
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)
}