Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var BalanceStrategy = map[string]sarama.BalanceStrategy{ "sticky": sarama.BalanceStrategySticky, "roundrobin": sarama.BalanceStrategyRoundRobin, "range": sarama.BalanceStrategyRange, }
Functions ¶
func NewConsumerGroup ¶
func NewProducer ¶
func NewProducer(maxRetry int, brokerList ...string) (sarama.SyncProducer, error)
Types ¶
type Admin ¶
type Admin struct {
sarama.ClusterAdmin
}
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
Consumer represents a Sarama consumer group consumer
func NewConsumer ¶
func NewConsumer() Consumer
func (*Consumer) Cleanup ¶
func (consumer *Consumer) Cleanup(sarama.ConsumerGroupSession) error
Cleanup is run at the end of a session, once all ConsumeClaim goroutines have exited
func (*Consumer) ConsumeClaim ¶
func (consumer *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
ConsumeClaim must start a consumer loop of ConsumerGroupClaim's Messages().
Click to show internal directories.
Click to hide internal directories.