Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetDefaultConfig ¶
GetDefaultConfig returns the configuration at ./config/test.yaml
Types ¶
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
func NewConsumer ¶
func (*Consumer) Consume ¶
func (c *Consumer) Consume(topic string) (chan *sarama.ConsumerMessage, chan *sarama.ConsumerError)
Click to show internal directories.
Click to hide internal directories.