Versions Compared

Old Version 10

changes.mady.by.user TEJAL ADSUL

Saved on

compared with

New Version 11

changes.mady.by.user TEJAL ADSUL

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Consider the dynamic configurations ssl.keystore.location, ssl.keystore.password and ssl.keystore.type are stored in vault and their values are resolved using a VaultConfigProvider. 

...
ssl.keystore.location=${vault:/path/to/variables.properties:ssl.keystore.location}

ssl.keystore.password=${vault:/path/to/variables.properties:ssl.keystore.password}

ssl.keystore.type=${vault:/path/to/variables.properties:ssl.keystore.type}
 
config.providers=vault
config.providers.file.class=org.apache.kafka.connect.configs.VaultConfigProvider

  • The user will update the ssl.keystore.location, ssl.keystore.password, ssl.keystore.type in the vault.
  • After the updates are complete he will send a adminClient request to the broker to notify the configs are updated.
  • Broker receives a alteredConfig request.
  • The broker will invoke the get function in VaultConfigProvider
  • The VaultConfigProvider will fetch the actual values for ssl.keystore.location, ssl.keystore.password, ssl.keystore.type from the vault.
  • The broker will then validate the configs and apply the changes.

...