producer

Documentation

Index

• type MessageEncoder
• type Producer
  • func New(topic string, notifsChan chan proto.Message, client sarama.Client, ...) (Producer, error)

Types

type MessageEncoder

type MessageEncoder func(string, sarama.Encoder, proto.Message) (*sarama.ProducerMessage, error)

MessageEncoder defines the encoding from topic, key, proto.Message to sarama.ProducerMessage

type Producer

type Producer interface {
	Run()
	Write(proto.Message)
	Stop()
}

Producer forwards messages recvd on a channel to kafka.

func New

func New(topic string, notifsChan chan proto.Message, client sarama.Client, key sarama.Encoder,
	encoder MessageEncoder) (
	Producer, error)

New creates new Kafka producer