Versions in this module Expand all Collapse all v2 v2.1.1 Mar 2, 2016 Changes in this version + var Logger sarama.StdLogger + type Config struct + MaxProcessingTime time.Duration + Offsets struct{ ... } + Zookeeper *kazoo.Config + func NewConfig() *Config + func (cgc *Config) Validate() error + type Consumer interface + Ack func(*sarama.ConsumerMessage) + Close func() error + Errors func() <-chan error + Interrupt func() + Messages func() <-chan *sarama.ConsumerMessage + func Join(group string, subscription Subscription, zookeeper string, config *Config) (Consumer, error) + type Subscription interface + JSON func() ([]byte, error) + WatchPartitions func(kazoo *kazoo.Kazoo) (kazoo.PartitionList, <-chan zk.Event, error) + func BlacklistSubscription(pattern *regexp.Regexp) Subscription + func StaticSubscription(subscription map[string]int) Subscription + func TopicSubscription(topics ...string) Subscription + func WhitelistSubscription(pattern *regexp.Regexp) Subscription + type SubscriptionPattern string + const SubscriptionPatternBlackList + const SubscriptionPatternStatic + const SubscriptionPatternWhiteList
Go to main page