producer

Documentation

Index

• type Producer
  • func NewProducer(logger *zap.Logger, brokers string, username string, password string, ...) (*Producer, error)
  • func (p *Producer) Close()
  • func (p *Producer) ProduceKafkaMessage(event *event.Event, channelReference eventingChannel.ChannelReference) error

Types

type Producer

type Producer struct {
	// contains filtered or unexported fields
}

Producer Struct

func NewProducer

func NewProducer(logger *zap.Logger, brokers string, username string, password string, metricsServer *prometheus.MetricsServer, healthServer *health.Server) (*Producer, error)

Initialize The Producer

func (*Producer) Close

func (p *Producer) Close()

Close The Producer (Stop Processing)

func (*Producer) ProduceKafkaMessage

func (p *Producer) ProduceKafkaMessage(event *event.Event, channelReference eventingChannel.ChannelReference) error

Produce A KafkaMessage From The Specified CloudEvent To The Specified Topic And Wait For The Delivery Report