Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { Brokers []string `envconfig:"KAFKA_ADDR"` KafkaMaxBytes int `envconfig:"KAFKA_MAX_BYTES"` KafkaVersion string `envconfig:"KAFKA_VERSION"` ConsumedTopic string `envconfig:"KAFKA_CONSUMED_TOPIC"` ConsumedGroup string `envconfig:"KAFKA_CONSUMED_GROUP"` GracefulShutdownTimeout time.Duration `envconfig:"GRACEFUL_SHUTDOWN_TIMEOUT"` Snooze bool `envconfig:"SNOOZE"` OverSleep bool `envconfig:"OVERSLEEP"` BatchSize int `envconfig:"KAFKA_BATCH_SIZE"` BatchWaitTime time.Duration `envconfig:"KAFKA_BATCH_WAIT_TIME"` }
Config is the kafka configuration for this example
Click to show internal directories.
Click to hide internal directories.