Versions in this module Expand all Collapse all v0 v0.1.0 Nov 16, 2020 Changes in this version + type ConfluentConsumer struct + func NewConfluentConsumer(kafkaURLs []string, topic, groupID string) (*ConfluentConsumer, error) + func (confluent ConfluentConsumer) Close() + func (confluent ConfluentConsumer) Subscribe(f func(message *message.Message) error) + type Consumer interface + Close func() + Subscribe func(f func(message *message.Message) error) + type GroupHandler struct + func (h GroupHandler) Cleanup(session sarama.ConsumerGroupSession) error + func (h GroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error + func (h GroupHandler) Setup(session sarama.ConsumerGroupSession) error + type SaramaConsumer struct + func NewSaramaConsumer(kafkaURLs []string, topic, groupID string) (*SaramaConsumer, error) + func (sarama SaramaConsumer) Close() + func (sarama SaramaConsumer) Subscribe(f func(message *message.Message) error) + type SegmentioConsumer struct + func NewSegmentioConsumer(kafkaURLs []string, topic, groupID string) (*SegmentioConsumer, error) + func (segmentio SegmentioConsumer) Close() + func (segmentio SegmentioConsumer) Subscribe(f func(message *message.Message) error)
Go to main page