Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateKeyMessage ¶
func CreateKeyMessage(topic string, key string, value []byte) *sarama.ProducerMessage
CreateKeyMessage creates producer-formatted message with key.
func CreateMessage ¶
func CreateMessage(topic string, value []byte) *sarama.ProducerMessage
CreateMessage creates keyless producer-formatted message.
Types ¶
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
Consumer wraps Sarama Consumer-Group.
func NewConsumer ¶
func NewConsumer(config *ConsumerConfig) (*Consumer, error)
NewConsumer returns a configured Sarama Consumer-Group.
func (*Consumer) Close ¶
Close stops the ConsumerGroup and detaches any running sessions. It is required to call this function before the object passes out of scope, as it will otherwise leak memory.
func (*Consumer) Consume ¶
Consume starts consuming messages using provided Context and ConsumerGroupHandler.
func (*Consumer) SaramaConsumer ¶
func (c *Consumer) SaramaConsumer() *sarama.ConsumerGroup
SaramaConsumer returns the wrapper Sarama Consumer-Group. Only use this when you really have to.
type ConsumerConfig ¶
type ConsumerConfig struct {
// Name for ConsumerGroup
GroupName string
KafkaBrokers []string
// Overwrites the default sarama-config
SaramaConfig *sarama.Config
Topics []string
}
ConsumerConfig wraps configuration for Sarama Consumer-Group.
type Producer ¶
type Producer struct {
sarama.AsyncProducer
}
Producer wraps sarama's AsyncProducer
func NewProducer ¶
func NewProducer(config *ProducerConfig) (*Producer, error)
NewProducer returns a configured Sarama AsyncProducer.
type ProducerConfig ¶
type ProducerConfig struct {
KafkaBrokers []string
// Allow overwriting default sarama-config
SaramaConfig *sarama.Config
}
ProducerConfig wraps configuration for producer
Source Files