messaging

Documentation

Index

• Variables
• type KafkaProducer
  • func NewKafkaProducer(bootstrapServers, topic, clientID, acks string) (*KafkaProducer, error)
  • func (kp *KafkaProducer) Produce(payload []byte) error
  • func (kp *KafkaProducer) Stop()

Variables

var ErrAlreadyStopped = fmt.Errorf("producer already stopped")

Types

type KafkaProducer

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

func NewKafkaProducer

func NewKafkaProducer(bootstrapServers, topic,
	clientID, acks string) (*KafkaProducer, error)

func (*KafkaProducer) Produce

func (kp *KafkaProducer) Produce(payload []byte) error

func (*KafkaProducer) Stop

func (kp *KafkaProducer) Stop()