franz

Documentation

Index

• Variables
• func CreateConsumerGroup(brokers, cg, username, password string, isSSL bool, certsPath string, ...) (*consumerGroup, error)
• func CreateProducer(brokers, username, password string, retries int, isSSL bool, certsPath string, ...) (*producer, error)

Variables

var (
	ErrCertificates        = fmt.Errorf("error loading certificates")
	ErrCertificateNotFound = fmt.Errorf("error certificate not found")
	ErrUserCertificate     = fmt.Errorf("error loading user certificate")
)

var ErrSendingMessage = errors.New("error sending message")

Functions

func CreateConsumerGroup

func CreateConsumerGroup(brokers, cg, username, password string, isSSL bool, certsPath string, isOldest bool, l logger.Logger) (*consumerGroup, error)

CreateConsumerGroup create and configure a new consumer group.

func CreateProducer

func CreateProducer(brokers, username, password string, retries int, isSSL bool, certsPath string, l logger.Logger) (*producer, error)

CreateProducer create and configure a new message sender.