Kafka Connectors

lenses-cli connectors --cluster-name="dev" 

#[[--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\"}"

lenses-cli connector create ./connector.yaml

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"