Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaOptions ¶
type KafkaOptions struct {
KafkaAddresses []string `` /* 175-byte string literal not displayed */
KafkaConsumerGroup string `` /* 158-byte string literal not displayed */
KafkaOffsetReset string `` //nolint:all
/* 147-byte string literal not displayed */
KafkaSecurityProtocol string `` //nolint:all
/* 138-byte string literal not displayed */
KafkaProperties []string `long:"kafka-property" env:"KAFKA_PROPERTY" description:"Rdkafka properties in key=value format"`
}
KafkaOptions provides simple flags for to create a kafka consumer
func (KafkaOptions) NewConsumer ¶ added in v2.2.41
func (opts KafkaOptions) NewConsumer(config kafka.ConfigMap) *kafka.Consumer
Click to show internal directories.
Click to hide internal directories.