Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Option ¶
type Option interface {
// contains filtered or unexported methods
}
Option is used to configure the Kafka producer
func WithErrorHandler ¶
WithErrorHandler specifies a custom error handler for the Kafka producer
func WithFlushInterval ¶
WithFlushInterval specifies a flush interval for the Kafka producer
func WithMaxRetries ¶
WithMaxRetries specifies the total number of times to retry sending a message
func WithVersion ¶
func WithVersion(version sarama.KafkaVersion) Option
WithVersion specified the kafka cluster version to connect to
type Producer ¶
type Producer struct {
// contains filtered or unexported fields
}
Producer is a Kafka producer based on Sarama
func NewProducer ¶
NewProducer creates a Kafka producer
Click to show internal directories.
Click to hide internal directories.