Documentation ¶
Index ¶
Constants ¶
View Source
const ModuleName = "kafka"
ModuleName is the name used in config file
Variables ¶
This section is empty.
Functions ¶
Types ¶
type OutputConfig ¶
type OutputConfig struct { config.OutputConfig Version string `json:"version"` // Kafka cluster version, eg: 0.10.2.0 Brokers []string `json:"brokers"` // Kafka bootstrap brokers to connect to, as a comma separated list Topics []string `json:"topics"` // Kafka topics to be consumed, as a comma separated list SecurityProtocol string `json:"security_protocol,omitempty"` // use SASL authentication User string `json:"sasl_username,omitempty"` // SASL authentication username Password string `json:"sasl_password,omitempty"` // SASL authentication password // contains filtered or unexported fields }
OutputConfig holds the configuration json fields and internal objects
func DefaultOutputConfig ¶
func DefaultOutputConfig() OutputConfig
DefaultOutputConfig returns an OutputConfig struct with default values
Click to show internal directories.
Click to hide internal directories.