kafka

Documentation

Index

• type Consumer
  • func (c *Consumer) GetConsumer() (*confluentkafka.Consumer, error)
  • func (c *Consumer) Initialize(Broker string, Group string, Topics []string, Timeout int)
  • func (c *Consumer) Listen(messageChan chan *confluentkafka.Message) error
• type Producer
  • func (p *Producer) Initialize(Broker string, Timeout int)
  • func (p *Producer) Produce(msg []byte, topic string) error

Types

type Consumer

type Consumer struct {
	Broker string
	Group  string
	Topics []string
	// contains filtered or unexported fields
}

func (*Consumer) GetConsumer

func (c *Consumer) GetConsumer() (*confluentkafka.Consumer, error)

func (*Consumer) Initialize

func (c *Consumer) Initialize(Broker string, Group string, Topics []string, Timeout int)

func (*Consumer) Listen

func (c *Consumer) Listen(messageChan chan *confluentkafka.Message) error

type Producer

type Producer struct {
	Broker string
	// contains filtered or unexported fields
}

func (*Producer) Initialize

func (p *Producer) Initialize(Broker string, Timeout int)

func (*Producer) Produce

func (p *Producer) Produce(msg []byte, topic string) error