config

Documentation

Index

• type Config
  • func Get() (*Config, error)

Types

type Config

type Config struct {
	Brokers                 []string      `envconfig:"KAFKA_ADDR"`
	KafkaMaxBytes           int           `envconfig:"KAFKA_MAX_BYTES"`
	KafkaVersion            string        `envconfig:"KAFKA_VERSION"`
	ProducedTopic           string        `envconfig:"KAFKA_PRODUCED_TOPIC"`
	WaitForProducerReady    bool          `envconfig:"KAFKA_WAIT_PRODUCER_READY"`
	KafkaSecProtocol        string        `envconfig:"KAFKA_SEC_PROTO"`
	KafkaSecCACerts         string        `envconfig:"KAFKA_SEC_CA_CERTS"`
	KafkaSecClientCert      string        `envconfig:"KAFKA_SEC_CLIENT_CERT"`
	KafkaSecClientKey       string        `envconfig:"KAFKA_SEC_CLIENT_KEY" json:"-"`
	KafkaSecSkipVerify      bool          `envconfig:"KAFKA_SEC_SKIP_VERIFY"`
	GracefulShutdownTimeout time.Duration `envconfig:"GRACEFUL_SHUTDOWN_TIMEOUT"`
	Chomp                   bool          `envconfig:"CHOMP_MSG"`
}

Config is the kafka configuration for this example

func Get

func Get() (*Config, error)