kafka

Documentation

Index

• type Config
• type Kafka
  • func (*Kafka) ParseConfig(baseDir string, bs []byte) (any, error)
  • func (*Kafka) Scrape(ctx context.Context, target string, c any, ss *types.Samples) error

Types

type Config

type Config struct {
	BaseDir      string `toml:"-"`
	KafkaVersion string `toml:"kafka_version" description:"Kafka broker version"`
	Namespace    string `toml:"namespace"`

	SaslEnabled            bool   `toml:"sasl_enabled" description:"Connect using SASL/PLAIN"`
	SASLHandshake          bool   `toml:"sasl_handshake" description:"Only set this to false if using a non-Kafka SASL proxy"`
	SaslUsername           string `toml:"sasl_username" description:"SASL user name"`
	SaslPassword           string `toml:"sasl_password" description:"SASL user password"`
	SaslMechanism          string `toml:"sasl_mechanism" description:"SASL mechanism can be plain, scram-sha512, scram-sha256"`
	SaslServiceName        string `toml:"sasl_service_name" description:"Service name when using Kerberos Auth"`
	SaslKerberosConfigPath string `toml:"sasl_kerberos_config_path" description:"Kerberos config path"`
	SaslRealm              string `toml:"sasl_realm" description:"Kerberos realm"`
	SaslKeytabPath         string `toml:"sasl_keytab_path" description:"Kerberos keytab file path"`
	SaslKerberosAuthType   string `toml:"sasl_kerberos_auth_type" description:"Kerberos auth type. Either 'keytabAuth' or 'userAuth'"`
	SaslDisablePAFXFast    bool   `toml:"sasl_disable_pafxfast" description:"Configure the Kerberos client to not use PA_FX_FAST"`

	TLSEnabled               bool   `toml:"tls_enabled" description:"Connect to Kafka using TLS"`
	TLSServerName            string `` /* 179-byte string literal not displayed */
	TLSCAFile                string `toml:"tls_ca_file" description:"The optional certificate authority file for Kafka TLS client authentication"`
	TLSCertFile              string `toml:"tls_cert_file" description:"The optional certificate file for Kafka client authentication"`
	TLSKeyFile               string `toml:"tls_key_file" description:"The optional key file for Kafka client authentication"`
	TLSInsecureSkipTLSVerify bool   `toml:"tls_insecure_skip_tls_verify" description:"If true, the server's certificate will not be checked for validity"`

	TopicFilter  string `toml:"topic_filter" description:"Regex that determines which topics to collect"`
	TopicExclude string `toml:"topic_exclude" description:"Regex that determines which topics to exclude"`
	GroupFilter  string `toml:"group_filter" description:"Regex that determines which consumer groups to collect"`
	GroupExclude string `toml:"group_exclude" description:"Regex that determines which consumer groups to exclude"`

	UseConsumeLagZookeeper bool     `toml:"use_consume_lag_zookeeper" description:"if you need to use a group from zookeeper"`
	ZookeeperServers       []string `toml:"zookeeper_server" description:"Address (hosts) of zookeeper server"`

	OffsetShowAll    *bool `` /* 135-byte string literal not displayed */
	ConcurrentEnable bool  `` /* 173-byte string literal not displayed */
	TopicWorkers     int   `toml:"topic_workers" description:"Number of topic workers"`
}

type Kafka

type Kafka struct {
}

func (*Kafka) ParseConfig

func (*Kafka) ParseConfig(baseDir string, bs []byte) (any, error)

func (*Kafka) Scrape

func (*Kafka) Scrape(ctx context.Context, target string, c any, ss *types.Samples) error