kafka

Documentation

Index

• type KafkaConsumer
  • func NewConsumer(message chan *ckafka.Message) *KafkaConsumer
  • func (k *KafkaConsumer) Consume()
• type Producer
  • func NewProducer() *Producer
  • func (p *Producer) Publish(message string, topic string) error

Types

type KafkaConsumer

type KafkaConsumer struct {
	Message chan *ckafka.Message
}

func NewConsumer

func NewConsumer(message chan *ckafka.Message) *KafkaConsumer

func (*KafkaConsumer) Consume

func (k *KafkaConsumer) Consume()

type Producer

type Producer struct {
	Handler *ckafka.Producer
}

func NewProducer

func NewProducer() *Producer

func (*Producer) Publish

func (p *Producer) Publish(message string, topic string) error