Categorygithub.com/open-telemetry/opentelemetry-collector-contrib/internal/kafka

# Packages

Package msk implements the required IAM auth used by AWS' managed Kafka platform to be used with the Surama kafka producer.

# Functions

ConfigureAuthentication configures authentication in sarama.Config.

# Structs

Authentication defines authentication.
AWSMSKConfig defines the additional SASL authentication measures needed to use AWS_MSK_IAM and AWS_MSK_IAM_OAUTHBEARER mechanism.
KerberosConfig defines kerberos configuration.
PlainTextConfig defines plaintext authentication.
SASLConfig defines the configuration for the SASL authentication.
XDGSCRAMClient uses xdg-go scram to authentication conversation.