producer

Documentation

Index

• type Producer
  • func NewProducer(brokers []string, topic string, config *types.Config) (Producer, error)

Types

type Producer

type Producer interface {
	//Send sends a message to Kafka and returns an error if it fails.
	Send(topic string, key []byte, value []byte) error
	// SendAsync sends a message to Kafka asynchronously and returns an error if it fails.
	SendAsync(topic string, key []byte, value []byte) error
	// Close closes the producer.
	Close() error
}

Producer interface defines the methods that can be used to produce messages to Kafka.

func NewProducer

func NewProducer(brokers []string, topic string, config *types.Config) (Producer, error)

NewProducer returns a new instance of a Kafka producer.