in signer/msk_auth_token_provider.go [330:343]
func addUserAgent(signedURL string) (string, error) {
parsedSignedURL, err := url.Parse(signedURL)
if err != nil {
return "", fmt.Errorf("failed to parse signed url: %w", err)
}
query := parsedSignedURL.Query()
userAgent := strings.Join([]string{LibName, version, runtime.Version()}, "/")
query.Set(UserAgentKey, userAgent)
parsedSignedURL.RawQuery = query.Encode()
return parsedSignedURL.String(), nil
}