Documentation
¶
Index ¶
Constants ¶
View Source
const ModuleName = "kafka"
ModuleName is the name used in config file
Variables ¶
View Source
var SHA256 scram.HashGeneratorFcn = sha256.New
View Source
var SHA512 scram.HashGeneratorFcn = sha512.New
Functions ¶
Types ¶
type InputConfig ¶
type InputConfig struct { config.InputConfig 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 Group string `json:"group"` // Kafka consumer group definition OffsetOldest bool `json:"offset_oldest"` // Kafka consumer consume initial offset from oldest Assignor string `json:"assignor"` // Consumer group partition assignment strategy (range, roundrobin) SecurityProtocol string `json:"security_protocol,omitempty"` // use SASL authentication SaslMechanism string `json:"sasl_mechanism,omitempty"` // use SASL mechanism User string `json:"sasl_username,omitempty"` // SASL authentication username Password string `json:"sasl_password,omitempty"` // SASL authentication password // contains filtered or unexported fields }
InputConfig holds the configuration json fields and internal objects
func DefaultInputConfig ¶
func DefaultInputConfig() InputConfig
DefaultInputConfig returns an InputConfig struct with default values
type SCRAMClient ¶
type SCRAMClient struct { *scram.Client *scram.ClientConversation scram.HashGeneratorFcn }
func (*SCRAMClient) Begin ¶
func (x *SCRAMClient) Begin(userName, password, authzID string) (err error)
func (*SCRAMClient) Done ¶
func (x *SCRAMClient) Done() bool
Click to show internal directories.
Click to hide internal directories.