Versions in this module Expand all Collapse all v0 v0.4.3 Apr 29, 2016 Changes in this version + var Log = log.New(os.Stderr, "librdkafka: ", log.Lshortfile) + func UnmarshalBuffer(bufferPtr *C.buffer_t) []byte + type Client struct + func NewProducer(config Config, handler MessageDelivery) (*Client, error) + func (cl *Client) Close() + func (cl *Client) GetAllocCounter() int64 + func (cl *Client) Poll(timeout time.Duration) + type Config struct + func NewConfig() Config + func (c *Config) Close() + func (c *Config) Set(key, value string) + func (c *Config) SetB(key string, value bool) + func (c *Config) SetI(key string, value int) + type ErrorHandle struct + func (l *ErrorHandle) Error() string + type Message interface + GetKey func() []byte + GetPayload func() []byte + GetUserdata func() []byte + type MessageDelivery interface + OnMessageDelivered func(userdata []byte) + OnMessageError func(reason string, userdata []byte) + type ResponseError struct + Code int + Userdata []byte + func (r ResponseError) Error() string + type Topic struct + func NewTopic(name string, config TopicConfig, client *Client) *Topic + func (t *Topic) Close() + func (t *Topic) GetName() string + func (t *Topic) Produce(msg Message) error + type TopicConfig struct + func NewTopicConfig() TopicConfig + func (c *TopicConfig) Close() + func (c *TopicConfig) Set(key, value string) + func (c *TopicConfig) SetB(key string, value bool) + func (c *TopicConfig) SetI(key string, value int) + func (c *TopicConfig) SetRandomPartitioner() + func (c *TopicConfig) SetRoundRobinPartitioner() v0.4.3-patch Jul 13, 2016
Go to main page