Versions in this module Expand all Collapse all v1 v1.0.0 Jan 12, 2018 Changes in this version + func NewClient(options ...func(*Client)) stream.Client + func ParseKafkaURL(uri string) (string, string, string, error) + type Client struct + ConsumerBrokers []string + ConsumerConfig *cluster.Config + ConsumerGroup string + ConsumerTopics []string + Logger *zap.Logger + ProducerBrokers []string + ProducerConfig *sarama.Config + ProducerTopics []string + func (c *Client) NewConsumer() stream.Consumer + func (c *Client) NewConsumerAndProducer() (stream.Consumer, stream.Producer) + func (c *Client) NewProducer() stream.Producer + type Consumer struct + func (c *Consumer) Close() (err error) + func (c *Consumer) Messages() <-chan *stream.Message + type Producer struct + func (p *Producer) Close() (err error) + func (p *Producer) Messages() chan<- *stream.Message + func (p *Producer) PartitionKey(f func(*stream.Message) []byte)