Documentation
¶
Index ¶
- func NewConsumerGroup(groupID string, address ...string) (group sarama.ConsumerGroup, err error)
- func NewMessage(topic string, key string, value string) (msg *sarama.ProducerMessage)
- func NewSyncProducer(address ...string) (producer sarama.SyncProducer, err error)
- func SendMessage(producer sarama.SyncProducer, msg *sarama.ProducerMessage) (partition int32, offset int64, err error)
- type ConsumerGroupHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewConsumerGroup ¶
func NewConsumerGroup(groupID string, address ...string) (group sarama.ConsumerGroup, err error)
func NewMessage ¶
func NewMessage(topic string, key string, value string) (msg *sarama.ProducerMessage)
func NewSyncProducer ¶
func NewSyncProducer(address ...string) (producer sarama.SyncProducer, err error)
func SendMessage ¶
func SendMessage(producer sarama.SyncProducer, msg *sarama.ProducerMessage) (partition int32, offset int64, err error)
Types ¶
type ConsumerGroupHandler ¶
type ConsumerGroupHandler struct{}
func (ConsumerGroupHandler) Cleanup ¶
func (ConsumerGroupHandler) Cleanup(_ sarama.ConsumerGroupSession) error
func (ConsumerGroupHandler) ConsumeClaim ¶
func (ConsumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
func (ConsumerGroupHandler) Setup ¶
func (ConsumerGroupHandler) Setup(_ sarama.ConsumerGroupSession) error
Source Files
Click to show internal directories.
Click to hide internal directories.