Kafka Connect - SSL Cert Reloading

Kafka Connect
1

Hi, is Kafka Connect able to dynamically reload SSL Cert if Certs are rotated?

Kafka supports dynamic reload, but from what I can tell from reading Kafka connect code, Kafka connect does not support it.

In the Kafka connect Rest Server code, the rest server sets the ssl factory for the listener. But the certs are never reloaded in sslContextFactory creation code, only set keystore is used and not set + reload keystore.

I have been having issues when my short lived cert is rotated and the non-leader hosts start throwing ssl cert expired exceptions.

Is there a way to enable dynamic SSL Cert reloading?

2

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.