producer

Documentation

Index

• type KafkaProducer
  • func NewKafkaProducer(configuration *configuration.KafkaConfiguration) (*KafkaProducer, error)
  • func (producer *KafkaProducer) Close()
  • func (producer *KafkaProducer) Produce(topic string, message any) error
• type Producer

Types

type KafkaProducer

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

func NewKafkaProducer

func NewKafkaProducer(configuration *configuration.KafkaConfiguration) (*KafkaProducer, error)

func (*KafkaProducer) Close

func (producer *KafkaProducer) Close()

func (*KafkaProducer) Produce

func (producer *KafkaProducer) Produce(topic string, message any) error

type Producer

type Producer interface {
	// Produce sends a message to the broker with the given topic
	Produce(topic string, message any) error
	// Close closes connection and frees any used resources
	Close()
}

Producer is responsible for sending messages over to the message broker