Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( //ErrEmptyBroker is returned when the the broker is missing from the Config struct ErrEmptyBroker = errors.New("bad config: empty broker") //ErrEmptyTopic is returned when the the Topic is missing from the Config struct ErrEmptyTopic = errors.New("bad config: empty topic") //ErrEmptyUsername is returned when the the Username is missing from the Config struct ErrEmptyUsername = errors.New("bad config: empty username") //ErrEmptyPassword is returned when the the Password is missing from the Config struct ErrEmptyPassword = errors.New("bad config: empty password") )
Functions ¶
func MustNewWithAuth ¶ added in v0.16.5
MustNewWithAuth creates a confluent-kafkam with authentication
Types ¶
type Config ¶ added in v0.2.1
type Config struct {
Brokers []string
GroupID string
Username string
Password string
SecurityProtocol string
CertificatePath string
// RDKafkaConfig can specify librdkafka configs. If this is variable is set, the
// other variables (Brokers, GroupID, Username and Password) are ignored
RDKafkaConfig *kafka.ConfigMap
Topics []string
// PoolTimeout is the value passed to the internal consumer.Pool(...)
// function. Default: 1s
PoolTimeout time.Duration
// DisableCommit indicates that offsets should never be commited, even
// after calling Done()
DisableCommit bool
}
Config contains the configuration necessary to build the confluent-kafka-go goduck.Stream
Source Files
Click to show internal directories.
Click to hide internal directories.