consumer

Documentation

Index

• Constants
• type Consumer
  • func NewConsumer(addr, topic, group string, partition int) *Consumer
  • func (c *Consumer) ConsumeEvent(messageChan chan kafka.Message)
  • func (c *Consumer) Stop()

Constants

const BATCH_MAX_BYTES = 10e6 // 10MB

const BATCH_MIN_BYTES = 10e3 // 10kB

Types

type Consumer

type Consumer struct {
	KafkaAddr string
	Topic     string
	Partition int
	Group     string
	// contains filtered or unexported fields
}

func NewConsumer

func NewConsumer(addr, topic, group string, partition int) *Consumer

If group is setted, partition will be ignored

func (*Consumer) ConsumeEvent

func (c *Consumer) ConsumeEvent(messageChan chan kafka.Message)

func (*Consumer) Stop

func (c *Consumer) Stop()