kafka

Documentation

Index

• func CreateKafkaConsumer(addrs []string, id, groupID string) (sarama.ConsumerGroup, error)
• type AsyncProducer
  • func NewAsyncProducer(ctx context.Context, id string, brokers []string) (*AsyncProducer, error)
  • func (kp *AsyncProducer) Close()
• type ZapSaramaLogger
  • func (l *ZapSaramaLogger) Print(v ...interface{})
  • func (l *ZapSaramaLogger) Printf(format string, v ...interface{})
  • func (l *ZapSaramaLogger) Println(v ...interface{})

Functions

func CreateKafkaConsumer

func CreateKafkaConsumer(addrs []string, id, groupID string) (sarama.ConsumerGroup, error)

Types

type AsyncProducer

type AsyncProducer struct {
	Producer sarama.AsyncProducer
	// contains filtered or unexported fields
}

func NewAsyncProducer

func NewAsyncProducer(ctx context.Context, id string, brokers []string) (*AsyncProducer, error)

func (*AsyncProducer) Close

func (kp *AsyncProducer) Close()

type ZapSaramaLogger

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

func (*ZapSaramaLogger) Print

func (l *ZapSaramaLogger) Print(v ...interface{})

func (*ZapSaramaLogger) Printf

func (l *ZapSaramaLogger) Printf(format string, v ...interface{})

func (*ZapSaramaLogger) Println

func (l *ZapSaramaLogger) Println(v ...interface{})