kafka

Documentation

Index

• type Consumer
  • func NewConsumer(configMap *ckafka.ConfigMap, topics []string) *Consumer
  • func (c *Consumer) Consume(ch chan<- *ckafka.Message) error
• type Producer
  • func NewProducer(configMap *ckafka.ConfigMap) *Producer
  • func (p *Producer) Publish(msg interface{}, key []byte, topic string) error

Types

type Consumer

type Consumer struct {
	ConfigMap *ckafka.ConfigMap
	Topics    []string
}

func NewConsumer

func NewConsumer(configMap *ckafka.ConfigMap, topics []string) *Consumer

func (*Consumer) Consume

func (c *Consumer) Consume(ch chan<- *ckafka.Message) error

type Producer

type Producer struct {
	ConfigMap *ckafka.ConfigMap
}

func NewProducer

func NewProducer(configMap *ckafka.ConfigMap) *Producer

func (*Producer) Publish

func (p *Producer) Publish(msg interface{}, key []byte, topic string) error