config

type Config struct {
	ClusterName     string               `yaml:"clusterName"`
	TargetNamespace string               `yaml:"namespace"`
	MaxEventAge     time.Duration        `yaml:"maxEventAge"`
	BufferSize      int                  `yaml:"bufferSize"`
	Kafka           *KafkaConfig         `yaml:"kafka"`
	Filters         []processor.Filter   `yaml:"filters"`
	Selectors       []processor.Selector `yaml:"selectors"`
}

type KafkaConfig struct {
	Brokers        []string     `yaml:"brokers"`
	Topic          string       `yaml:"topic"`
	RawCompression string       `yaml:"compression" default:"none"`
	RawTLS         *RawTLSData  `yaml:"tls"`
	RawSASL        *RawSASLData `yaml:"sasl"`
}

type RawSASLData struct {
	Username  string `yaml:"username"`
	Password  string `yaml:"password"`
	Mechanism string `yaml:"mechanism" default:"plain"`
}

type RawTLSData struct {
	CA         string `yaml:"cacert"`
	Cert       string `yaml:"cert"`
	Key        string `yaml:"key"`
	SkipVerify bool   `yaml:"skipVerify"`
}