Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewConsumer ¶
func NewConsumer(conf KafkaConfig) (sarama.Consumer, error)
NewConsumer new kafka consumer
func NewConsumerGroup ¶
func NewConsumerGroup(conf KafkaConfig, group string) (sarama.ConsumerGroup, error)
NewConsumerGroup new kafka consumer group
Types ¶
Click to show internal directories.
Click to hide internal directories.