Categorygithub.com/sciclon2/kafka-lag-gopkgkafka
package
3.0.0+incompatible
Repository: https://github.com/sciclon2/kafka-lag-go.git
Documentation: pkg.go.dev
Overview
Versions
3
Dependencies
16
Dependents
7
Files
728 SLOC

# Functions

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
NewCustomBroker creates a new CustomBroker and sets the broker ID.

# Structs

CustomBroker wraps sarama.Broker and allows setting the Broker ID.
MockKafkaAdmin mocks the KafkaAdmin interface for testing.
MockKafkaClient mocks the KafkaClient interface for testing.
XDGSCRAMClient is a struct that wraps the scram.Client and provides methods for SASL SCRAM authentication.