define kafkaconnect worker consumer configurations

[cstmgl]

Hi All,
I have a question about how to define the Kafka Connect worker consumer configurations.
I've been reading a little and I think they need to be defined at the worker level and for example I could override them at each Connector level if I would define the override policy also at the worker level
connector.client.config.override.policy

Now my assumption is that the worker level would mean that I defined this together with my KafkaConnect CRD but I'm not sure this works because I get some warnings in the logs that some of this properties are defined but do not exist (when I look at the logs in the instance).

So I just wanted to know if there is any example of this, I also did a quick browse on the documentation but did not find something specific to this, but I might have overlooked something.

Thank you for any feedback

just for reference this are the warnings I mean I get on startup of my pods:

[scholzj]

I think you can just ignore these warnings. Kafka just takes the configuration and passes it to every kind of component. And not all of the options are valid for every components. So they produce these kind of warnings. But the component which supports them will find them and use them.

[tusharbhasme]

Sure, how do I help?

[scholzj]

You can just give it a try and see if it works for you, if you run into any issues etc.

[tusharbhasme]

Sadly we are still on 0.21 without a plan to upgrade yet. :-(
In the meantime, can you share the issue, that we can track, under which the Connect's TLS setup will be changed to use PEM format?

[scholzj]

I do not think it has an issue, that is why I said you can open one if you want - sorry if I was not clear. But it is part of a bigger plan to get rid of the certificate processing in the images (and ideally get rid of OpenSSL).

[tusharbhasme]

#5189