kafka

Documentation

Index

• func NewKafkaProducer() *ckafka.Producer
• func Publish(msg string, topic string, producer *ckafka.Producer) error
• type KafkaComsumer
  • func NewKafkaComsumer(msgChan chan *ckafka.Message) *KafkaComsumer
  • func (k *KafkaComsumer) Consume()

Functions

func NewKafkaProducer

func NewKafkaProducer() *ckafka.Producer

create new producer

func Publish

func Publish(msg string, topic string, producer *ckafka.Producer) error

publish a new message

Types

type KafkaComsumer

type KafkaComsumer struct {
	MsgChan chan *ckafka.Message
}

func NewKafkaComsumer

func NewKafkaComsumer(msgChan chan *ckafka.Message) *KafkaComsumer

Fabric Pattern

func (*KafkaComsumer) Consume

func (k *KafkaComsumer) Consume()

kafka message consuming