Versions in this module Expand all Collapse all v1 v1.0.0 Feb 15, 2019 Changes in this version + type Client struct + Config *Config + func NewClient(config *Config) *Client + func (client *Client) AsyncSend(message *Message) error + func (client *Client) Close() + func (client *Client) MarkOffset(topic string, partition int, offset int, metadata ...string) error + func (client *Client) Receive() (*Message, error) + func (client *Client) SyncSend(message *Message) error + func (client *Client) Topics() ([]string, error) + type Config struct + AutoMarkOffset bool + GroupId string + Servers string + Topics string + func NewConfig() *Config + type Message struct + Key []byte + Offset int + Partition int + Topic string + Value []byte + func (msg *Message) MarkOffset()