kafka

Documentation

Index

• func StartReceive(r Reader, f func([]byte))
• type KafkaMsg
• type KafkaStub
  • func NewKafkaStub(ctx context.Context, brokers []string) (k *KafkaStub, err error)
  • func (k *KafkaStub) NewConsumerGroup(ctx context.Context, groupName string, topics []string, f func([]byte))
  • func (k *KafkaStub) SendMessageAsync(ctx context.Context, topic, content string)
• type Message
• type Reader
  • func (consumer *Reader) Cleanup(sarama.ConsumerGroupSession) error
  • func (consumer *Reader) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (consumer *Reader) Setup(sarama.ConsumerGroupSession) error

Functions

func StartReceive

func StartReceive(r Reader, f func([]byte))

Types

type KafkaMsg

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

type KafkaStub

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

func NewKafkaStub

func NewKafkaStub(ctx context.Context, brokers []string) (k *KafkaStub, err error)

func (*KafkaStub) NewConsumerGroup

func (k *KafkaStub) NewConsumerGroup(ctx context.Context, groupName string, topics []string, f func([]byte))

func (*KafkaStub) SendMessageAsync

func (k *KafkaStub) SendMessageAsync(ctx context.Context, topic, content string)

type Message

type Message struct {
	Id        uint64 `json:"id"`
	Type      int    `json:"type"`
	Content   string `json:"content"`
	Timestamp int64  `json:"timestamp"`
}

type Reader

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

func (*Reader) Cleanup

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

Cleanup is run at the end of a session, once all ConsumeClaim goroutines have exited

func (*Reader) ConsumeClaim

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

ConsumeClaim must start a consumer loop of ConsumerGroupClaim's Messages().

func (*Reader) Setup

func (consumer *Reader) Setup(sarama.ConsumerGroupSession) error

Setup is run at the beginning of a new session, before ConsumeClaim