kafka

Documentation

Index

• Variables
• type Arguments
  • func (a *Arguments) Convert() *kafka_exporter.Config
  • func (a *Arguments) SetToDefault()
  • func (a *Arguments) Validate() error

Variables

var DefaultArguments = Arguments{
	UseSASLHandshake:        true,
	KafkaVersion:            sarama.V2_0_0_0.String(),
	MetadataRefreshInterval: "1m",
	AllowConcurrent:         true,
	MaxOffsets:              1000,
	PruneIntervalSeconds:    30,
	OffsetShowAll:           true,
	TopicWorkers:            100,
	TopicsFilter:            ".*",
	TopicsExclude:           "^$",
	GroupFilter:             ".*",
	GroupExclude:            "^$",
}

Types

type Arguments

type Arguments struct {
	Instance                string            `river:"instance,attr,optional"`
	KafkaURIs               []string          `river:"kafka_uris,attr,optional"`
	UseSASL                 bool              `river:"use_sasl,attr,optional"`
	UseSASLHandshake        bool              `river:"use_sasl_handshake,attr,optional"`
	SASLUsername            string            `river:"sasl_username,attr,optional"`
	SASLPassword            rivertypes.Secret `river:"sasl_password,attr,optional"`
	SASLMechanism           string            `river:"sasl_mechanism,attr,optional"`
	SASLDisablePAFXFast     bool              `river:"sasl_disable_pafx_fast,attr,optional"`
	UseTLS                  bool              `river:"use_tls,attr,optional"`
	TlsServerName           string            `river:"tls_server_name,attr,optional"`
	CAFile                  string            `river:"ca_file,attr,optional"`
	CertFile                string            `river:"cert_file,attr,optional"`
	KeyFile                 string            `river:"key_file,attr,optional"`
	InsecureSkipVerify      bool              `river:"insecure_skip_verify,attr,optional"`
	KafkaVersion            string            `river:"kafka_version,attr,optional"`
	UseZooKeeperLag         bool              `river:"use_zookeeper_lag,attr,optional"`
	ZookeeperURIs           []string          `river:"zookeeper_uris,attr,optional"`
	ClusterName             string            `river:"kafka_cluster_name,attr,optional"`
	MetadataRefreshInterval string            `river:"metadata_refresh_interval,attr,optional"`
	ServiceName             string            `river:"gssapi_service_name,attr,optional"`
	KerberosConfigPath      string            `river:"gssapi_kerberos_config_path,attr,optional"`
	Realm                   string            `river:"gssapi_realm,attr,optional"`
	KeyTabPath              string            `river:"gssapi_key_tab_path,attr,optional"`
	KerberosAuthType        string            `river:"gssapi_kerberos_auth_type,attr,optional"`
	OffsetShowAll           bool              `river:"offset_show_all,attr,optional"`
	TopicWorkers            int               `river:"topic_workers,attr,optional"`
	AllowConcurrent         bool              `river:"allow_concurrency,attr,optional"`
	AllowAutoTopicCreation  bool              `river:"allow_auto_topic_creation,attr,optional"`
	MaxOffsets              int               `river:"max_offsets,attr,optional"`
	PruneIntervalSeconds    int               `river:"prune_interval_seconds,attr,optional"` // deprecated - no-op
	TopicsFilter            string            `river:"topics_filter_regex,attr,optional"`
	TopicsExclude           string            `river:"topics_exclude_regex,attr,optional"`
	GroupFilter             string            `river:"groups_filter_regex,attr,optional"`
	GroupExclude            string            `river:"groups_exclude_regex,attr,optional"`
}

func (*Arguments) Convert

func (a *Arguments) Convert() *kafka_exporter.Config

func (*Arguments) SetToDefault

func (a *Arguments) SetToDefault()

SetToDefault implements river.Defaulter.

func (*Arguments) Validate

func (a *Arguments) Validate() error

Validate implements river.Validator.