kafka_input

package

v0.44.1 Latest Latest Go to latest Published: Feb 20, 2026 License: Apache-2.0 Imports: 28 Imported by: 0

Details

This section is empty.

View Source

var SHA256 scram.HashGeneratorFcn = func() hash.Hash { return sha256.New() }

View Source

var SHA512 scram.HashGeneratorFcn = func() hash.Hash { return sha512.New() }

This section is empty.

type KafkaInput struct {
	inputs.BaseInput
	// contains filtered or unexported fields
}

KafkaInput //

func (k *KafkaInput) Close() error

func (k *KafkaInput) Start(ctx context.Context, name string, cfg map[string]interface{}, opts ...inputs.Option) error

func (k *KafkaInput) Update(cfg map[string]any) error

Update updates the input configuration and restarts the workers if necessary. It works only when the command is collector (not subscribe).

func (k *KafkaInput) UpdateProcessor(name string, pcfg map[string]any) error

func (k *KafkaInput) Validate(cfg map[string]any) error

type XDGSCRAMClient struct {
	*scram.Client
	*scram.ClientConversation
	scram.HashGeneratorFcn
}

func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)

func (x *XDGSCRAMClient) Done() bool

func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)