Skip to content

Provides an implementation of ConfigProvider that allows variable references to be replaced dynamically with values from Secrets on each worker.

License

Notifications You must be signed in to change notification settings

gustajz/kubernetes-config-provider

Repository files navigation

Kubernetes Config Provider

Development

./gradlew clean build shadowJar

Usage

  1. Copy uberjar to /usr/share/java/kafka/.

  2. Configure provider in Kafka Connect.

config.providers=secrets
config.providers.secrets.class=com.github.gustajz.kafka.config.provider.KubernetesSecretConfigProvider
config.providers.secrets.param.namespace=default

If you are using Docker or Kubernetes, you can set environment variables

CONNECT_CONFIG_PROVIDERS: secrets
CONNECT_CONFIG_PROVIDERS_SECRETS_CLASS: com.github.gustajz.kafka.config.provider.KubernetesSecretConfigProvider
CONNECT_CONFIG_PROVIDERS_SECRETS_PARAM_NAMESPACE: default
  1. Configure connector with secure properties.
username=${secrets:my-secret:my_username_key}
password=${secrets:my-secret:my_password_key}

More Documentation

License

This project is licensed under the Apache License Version 2.0 (see LICENSE).

About

Provides an implementation of ConfigProvider that allows variable references to be replaced dynamically with values from Secrets on each worker.

Topics

Resources

License

Stars

Watchers

Forks

Packages

No packages published

Languages