producer

Documentation

Index

• type Producer
  • func NewProducer(brokers []string) (*Producer, error)
  • func (p *Producer) Close() error
  • func (p *Producer) GetProducedMessages() (uint64, uint64)
  • func (p *Producer) SendMessage(message *shared.KafkaMessage)

Types

type Producer

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

Producer struct wraps a sarama.AsyncProducer and handles Kafka message production.

func NewProducer

func NewProducer(brokers []string) (*Producer, error)

NewProducer creates a new Producer with the given Kafka brokers.

func (*Producer) Close

func (p *Producer) Close() error

Close stops the producer and returns any errors during closure.

func (*Producer) GetProducedMessages

func (p *Producer) GetProducedMessages() (uint64, uint64)

GetProducedMessages returns the count of produced and errored messages.

func (*Producer) SendMessage

func (p *Producer) SendMessage(message *shared.KafkaMessage)

SendMessage sends a KafkaMessage to the producer.