kafka

package

v0.0.0-...-d36e230 Latest Latest Go to latest Published: Jun 23, 2023 License: GPL-3.0 Imports: 1 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

Função consumir pro kafka

func (c *Consumer) Consume(msgChan chan *ckafka.Message) error

Método canal que recebe as msg ckafka.Message

type Producer struct {
	ConfigMap *ckafka.ConfigMap
}

func NewKafkaProducer(configMap *ckafka.ConfigMap) *Producer

Função de produzir novas msg no kafka

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

Método msg de published