You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Kirk True (Jira)" <ji...@apache.org> on 2024/08/13 18:40:00 UTC

[jira] [Created] (KAFKA-17335) Lack of default for missing URL encoding option for OAuth causes NPE

Kirk True created KAFKA-17335:
---------------------------------

             Summary: Lack of default for missing URL encoding option for OAuth causes NPE
                 Key: KAFKA-17335
                 URL: https://issues.apache.org/jira/browse/KAFKA-17335
             Project: Kafka
          Issue Type: Bug
          Components: clients, security
    Affects Versions: 3.9.0
            Reporter: Kirk True
            Assignee: Kirk True
             Fix For: 4.0.0


KAFKA-16345 added a new client configuration option {{{}SASL_OAUTHBEARER_HEADER_URLENCODE{}}}. This is an optional configuration, so the user doesn't need to provide it. When an {{{}AdminConfig{}}}, {{{}ConsumerConfig{}}}, or {{ProducerConfig}} object is created, it uses the default value of {{DEFAULT_SASL_OAUTHBEARER_HEADER_URLENCODE}} if the value isn't present.

However, if the configuration is created as a plain {{Map}} or {{Properties}} and the {{sasl.oauthbearer.header.urlencode}} key isn't present, it can lead to a {{{}NullPointerException{}}}. This occurs because the code in {{AccessTokenRetriever.create()}} assumes that there's always a value present in the incoming {{configs}} parameter. But if there isn't an entry for the {{sasl.oauthbearer.header.urlencode}} key in the map, a {{NullPointerException}} is thrown.

When using map-based configuration, one workaround is to explicitly add an entry to the map like so:
{code:java}
Map<String, Object> configs = new HashMap();
. . .
configs.put(SASL_OAUTHBEARER_HEADER_URLENCODE, DEFAULT_SASL_OAUTHBEARER_HEADER_URLENCODE);
. . .
configureSomething(configs);{code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)