internal

Documentation

Index

• type Consumer
  • func NewConsumer(groupID string, conf *kafka.ConfigMap) (*Consumer, error)
  • func (c *Consumer) Receive(ctx context.Context, topic string) (chan *kafka.Message, error)
• type Producer
  • func NewProducer(conf *kafka.ConfigMap) (*Producer, error)
  • func (p *Producer) Send(ctx context.Context, n int) (int, error)

Types

type Consumer

type Consumer struct {
	*kafka.Consumer
}

func NewConsumer

func NewConsumer(groupID string, conf *kafka.ConfigMap) (*Consumer, error)

func (*Consumer) Receive

func (c *Consumer) Receive(ctx context.Context, topic string) (chan *kafka.Message, error)

type Producer

type Producer struct {
	*kafka.Producer
}

func NewProducer

func NewProducer(conf *kafka.ConfigMap) (*Producer, error)

func (*Producer) Send

func (p *Producer) Send(ctx context.Context, n int) (int, error)