goo_kafka

Documentation

Index

• func Client() *client
• func Consumer() iConsumer
• func Init(user, password string, addrs ...string) error
• func Producer() iProducer
• type ConsumerError
• type ConsumerHandler
• type ConsumerMessage

Functions

func Client

func Client() *client

func Consumer

func Consumer() iConsumer

func Init

func Init(user, password string, addrs ...string) error

func Producer

func Producer() iProducer

Types

type ConsumerError

type ConsumerError struct {
	*sarama.ConsumerError
}

type ConsumerHandler

type ConsumerHandler func(msg *ConsumerMessage, err *ConsumerError) error

type ConsumerMessage

type ConsumerMessage struct {
	*sarama.ConsumerMessage
}