Hi Kafka team,

Currently I'm investigating the config.action.reload feature of Kafka
Connect. I'm wondering how to enable this feature. E.g. If I use the
FileConfigProvider,
clients/src/main/java/org/apache/kafka/common/config/provider/FileConfigProvider.java
is it enough to set the config.action.reload = true in the connector
configs? Or I have to implement my own subscribe and unsubscribe logic
before using it?
https://github.com/a0x8o/kafka/blob/54eff6af115ee647f60129f2ce6a044cb17215d0/clients/src/main/java/org/apache/kafka/common/config/provider/ConfigProvider.java#L52-L73

What's more interesting is I noticed Herder should have corresponding logic
to handle the onChange() function, but I didn't find how the function is
used in Herder. I'm curious what's the best practice to use the feature to
update the value from ConfigProvider? Thanks!
[image: image.png]

Reply via email to