Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AuthConfig ¶
type AuthConfig struct { TLS struct { // Whether to use TLS when connecting to the broker // (defaults to false). Enabled bool `mapstructure:"enabled"` // controls whether a client verifies the server's certificate chain and host name // defaults to false InsecureSkipVerify bool `mapstructure:"insecure_skip_verify"` // certificate file for client authentication CertFile string `mapstructure:"cert_file"` // key file for client authentication KeyFile string `mapstructure:"key_file"` // certificate authority file for TLS client authentication CAFile string `mapstructure:"ca_file"` } `mapstructure:"tls"` }
type Config ¶
type Config struct { Broker string `mapstructure:"broker" validate:"required"` Auth AuthConfig `mapstructure:"auth_config"` }
Config holds the set of configuration for the kafka extractor
type Extractor ¶
type Extractor struct { plugins.BaseExtractor // contains filtered or unexported fields }
Extractor manages the extraction of data from a kafka broker
Click to show internal directories.
Click to hide internal directories.