kafka

Documentation

Index

• type Kafka
  • func NewKafka(addrs []string) *Kafka
  • func (k *Kafka) AsyncProducer(ctx context.Context, msg chan *sarama.ProducerMessage, sf successFunc, ...)
  • func (k *Kafka) Close()
  • func (k *Kafka) Consumer(ctx context.Context, topic string, partition int32, offset int64, rf rmsgFunc, ...)
  • func (k *Kafka) ConsumerGroup(ctx context.Context, gid string, topics []string, rf rmsgFunc)
  • func (k *Kafka) SyncProducer(msg *sarama.ProducerMessage) (part int32, offset int64, err error)

Types

type Kafka

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

func NewKafka

func NewKafka(addrs []string) *Kafka

func (*Kafka) AsyncProducer

func (k *Kafka) AsyncProducer(ctx context.Context, msg chan *sarama.ProducerMessage, sf successFunc, ef errorFunc)

func (*Kafka) Close

func (k *Kafka) Close()

func (*Kafka) Consumer

func (k *Kafka) Consumer(ctx context.Context, topic string, partition int32, offset int64, rf rmsgFunc, ef rerrFunc)

func (*Kafka) ConsumerGroup

func (k *Kafka) ConsumerGroup(ctx context.Context, gid string, topics []string, rf rmsgFunc)

func (*Kafka) SyncProducer

func (k *Kafka) SyncProducer(msg *sarama.ProducerMessage) (part int32, offset int64, err error)

同步消息模式