Hi,

I guess you are using the Endpoint DSL? Which Camel version do you use
here?

In case you are running Camel 3.7.0, I recall the additionalProperties was
broken in the kafka component and it was fixed in 3.7.1 and 3.8.0.

Regards,
Omar

On Wed, Apr 28, 2021 at 3:19 PM anandakrishnan ramakrishnan <
anand140...@gmail.com> wrote:

> I am having issue with setting additionalProperties. I am setting the
> property as below
>
>     Map<String, String> additionalProperties = new HashMap<>();
>             additionalProperties.put("sasl.login.callback.handler.class",
>
>
>  
> "io.confluent.kafka.clients.plugins.auth.token.TokenUserLoginCallbackHandler");
>
> Followed by the Kafka route builder is setup as below
>
>     .additionalProperties(additionalProperties)
>
> However the property i see populated in the kafka config show up as
>
> "sasl"->"io.confluent.kafka.clients.plugins.auth.token.TokenUserLoginCallbackHandler"
>
> The reason being the PropertyBindingSupport.java is splitting by dot
>
> // we should only walk and create OGNL path for the middle graph
>
>     String[] parts;
>     if (isDotKey(name)) {
>         parts = splitKey(name);
>     } else {
>         parts = new String[] { name };
>     }
>
> // which only picks up "sasl" instead of
> "sasl.login.callback-handler.class"
>
>     newName = parts[i + 1];
>
> Any help is appreciated.
>

Reply via email to