kafka

Documentation

Index

• func Consume(client sarama.Consumer, topic string, message chan []byte)
• func ConsumeGroup(ctx context.Context, client sarama.ConsumerGroup, topic string, ...)
• func Produce(client sarama.AsyncProducer, topic string, msg *helpermsg.Message)
• type ConsumerGroup
  • func (consumer *ConsumerGroup) Cleanup(sarama.ConsumerGroupSession) error
  • func (consumer *ConsumerGroup) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (cg *ConsumerGroup) Setup(sarama.ConsumerGroupSession) error

Functions

func Consume

func Consume(client sarama.Consumer, topic string, message chan []byte)

func ConsumeGroup

func ConsumeGroup(ctx context.Context, client sarama.ConsumerGroup, topic string, message chan []byte)

func Produce

func Produce(client sarama.AsyncProducer, topic string, msg *helpermsg.Message)

Types

type ConsumerGroup

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

func (*ConsumerGroup) Cleanup

func (consumer *ConsumerGroup) Cleanup(sarama.ConsumerGroupSession) error

func (*ConsumerGroup) ConsumeClaim

func (consumer *ConsumerGroup) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (*ConsumerGroup) Setup

func (cg *ConsumerGroup) Setup(sarama.ConsumerGroupSession) error