Charmed Apache Kafka Connect K8s
| Channel | Revision | Published | Runs on |
|---|---|---|---|
| latest/edge | 17 | 16 Feb 2026 |
juju deploy kafka-connect-k8s --channel latest/edge
Deploy Kubernetes operators easily with Juju, the Universal Operator Lifecycle Manager. Need a Kubernetes cluster? Install MicroK8s to create a full CNCF-certified Kubernetes system in under 60 seconds.
Platform:
-
exactly_once_source_support | boolean
Whether to enable exactly-once support for source connectors in the cluster by using transactions to write source records and their source offsets, and by proactively fencing out old task generations before bringing up new ones.
-
key_converter | string
Default: org.apache.kafka.connect.json.JsonConverter
Converter class used to convert between Kafka Connect format and the serialized form that is written to Kafka. This controls the format of the keys in messages written to or read from Kafka, and since this is independent of connectors, it allows any connector to work with any serialization format. Examples of common formats include JSON and Avro.
Note: For custom converters, the library files should be provided to the charm beforehand using
juju attach-resourcecommand. Please refer to the docs for more details. -
log_level | string
Default: INFO
Level of logging for the Apache Kafka Connect service operated by the charm.
Allowed values are: "ERROR", "WARNING", "INFO", and "DEBUG".
-
profile | string
Default: production
Profile representing the scope of deployment, and used to enable high-level customisation of configs, resource checks/allocation, logging levels, etc.
Allowed values are: "production" and "testing".
-
rest_port | int
Default: 8083
Port used for Apache Kafka Connect REST API endpoint.
-
system-users | string
User-provided secret ID which defines custom username/passwords on the Kafka Connect REST Interface. The secret ID format is like "secret:cvh7kruupa1s46bqvuig" and should not be confused with secret name or label.
The secret could be defined using
juju add-secret <secret-name> u1=p1 u2=p2 ...command, where keys (u1..n) are usernames and values (p1..n) are passwords. Thejuju add-secretcommand will output the secret ID, which can then be granted to the charm and configured usingjuju configcommand. The following example shows the complete flow:$ juju add-secret my-auth admin=adminpass user1=user1pass user2=user2pass
some ID will be printed: e.g. "secret:cvh7kruupa1s46bqvuig". take note of that.
$ juju grant-secret my-auth kafka-connect $ juju config kafka-connect auth=secret:cvh7kruupa1s46bqvuig
-
value_converter | string
Default: org.apache.kafka.connect.json.JsonConverter
Converter class used to convert between Kafka Connect format and the serialized form that is written to Kafka. This controls the format of the values in messages written to or read from Kafka, and since this is independent of connectors, it allows any connector to work with any serialization format. Examples of common formats include JSON and Avro.
Note: For custom converters, the library files should be provided to the charm beforehand using
juju attach-resourcecommand. Please refer to the docs for more details.