kafka_input

package

v0.42.1 Latest Latest Go to latest Published: Oct 20, 2025 License: Apache-2.0 Imports: 23 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 {
	Cfg *config
	// 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

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)