kafka

Documentation

Index

• Variables
• func StartConsumerGroup(ctx context.Context, brokers []string) error
• type Consumer
  • func (g *Consumer) Cleanup(_ sarama.ConsumerGroupSession) error
  • func (g *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (g *Consumer) Setup(_ sarama.ConsumerGroupSession) error

Variables

var (
	Topic           string
	ProtocolVersion = sarama.V3_0_0_0
	GroupID         string
)

Functions

func StartConsumerGroup

func StartConsumerGroup(ctx context.Context, brokers []string) error

Types

type Consumer

type Consumer struct {
	// contains filtered or unexported fields
}

func (*Consumer) Cleanup

func (g *Consumer) Cleanup(_ sarama.ConsumerGroupSession) error

func (*Consumer) ConsumeClaim

func (g *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (*Consumer) Setup

func (g *Consumer) Setup(_ sarama.ConsumerGroupSession) error