View the latest documentation 5.3
The CLI can create, modify, pause, restart and remove Apache Kafka Connect connectors.
Note: Kafka Connect cluster permissions will be applied to the operation.
List currently deployed connectors, optionally filter by name, cluster and namespace:
lenses-cli connectors --cluster-name="dev" #[[--names [--unwrap]]
The --names flag displays only the names of the connectors. When used with --unwrap, it will print each connector name on a separate line in the output.
--names
--unwrap
lenses-cli connectors --supported
lenses-cli connectors plugins --cluster-name="dev"
lenses-cli connector create \ --cluster-name="dev" \ --name="connectorName" \ --configs="{\"key\": \"value\"}"
From a file:
lenses-cli connector create ./connector.yaml
Example file:
clusterName: development config: connector.class: "org.apache.kafka.connect.file.FileStreamSinkConnector" file: "/dev/null" tasks.max: "1" topics: "reddit_posts" name: "nullsink"
# Inline lenses-cli connector update --name=nullsink --cluster-name=dev \ --configs="{\"connector.class\":\"org.apache.kafka.connect.file.FileStreamSinkConnector\",\"file\":\"/dev/null\",\"name\":\"nullsink\",\"tasks.max\":\"8\",\"topics\":\"reddit_posts\"}" # or from file lenses-cli connector update ./connector.yaml
lenses-cli connector config \ --cluster-name="dev" \ --name="connectorName"
lenses-cli connector status \ --cluster-name="dev" \ --name="connectorName"
lenses-cli connector pause \ --cluster-name="dev" \ --name="connectorName"
lenses-cli connector resume \ --cluster-name="dev" \ --name="connectorName"
lenses-cli connector restart \ --cluster-name="dev" \ --name="connectorName"
lenses-cli connector task restart \ --task=0 \ --cluster-name="dev" \ --name="connectorName"
lenses-cli connector tasks \ --cluster-name="dev" \ --name="connectorName"
lenses-cli connector task status \ --cluster-name="dev" \ --name="connectorName" --task=1
lenses-cli connector delete \ --cluster-name="dev" \ --name="connectorName"
On this page