Kafka Connect Manager
A tool to manage Apache Kafka Connect connectors and tasks
Usage:
$ kcm [OPTIONS] COMMAND [ARGS]...
Options:
-
--host TEXT
: Connect worker host [env var: CONNECT_HOST; default: http://localhost:8083] -
--install-completion
: Install completion for the current shell. -
--show-completion
: Show completion for the current shell, to copy it or customize the installation. -
--help
: Show this message and exit.
Commands:
-
add
: Register new connector Supporting environment... -
list
: List all connectors -
status
: Get status connector -
update
: Update connector configuration -
watch
: Actively monitor your connectors health
kcm add
Register new connector
Supporting environment variable expansion in JSON file.
A connector requires a name and configuration, we take both of them separately.
For example:
{
"name": "MySinkConnector",
"config": {
"connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
"connection.uri": "${MONGODB_URL}"
}
}
Usage:
$ kcm add [OPTIONS]
Options:
-
-f, --file FILE
: Config JSON file path [required] -
--help
: Show this message and exit.
kcm list
List all connectors
Usage:
$ kcm list [OPTIONS]
Options:
-
--type [all|sink|source]
: Type of connectors to list [default: all] -
--help
: Show this message and exit.
kcm status
Get status connector
Usage:
$ kcm status [OPTIONS]
Options:
-
--connector TEXT
: Name of connector [required] -
--help
: Show this message and exit.
kcm update
Update connector configuration
Usage:
$ kcm update [OPTIONS] CONNECTOR
Arguments:
-
CONNECTOR
: Connector name [required]
Options:
-
-f, --file FILE
: Config JSON file path [required] -
--help
: Show this message and exit.
kcm watch
Actively monitor your connectors health
Usage:
$ kcm watch [OPTIONS] [CONNECTORS]...
Arguments:
-
[CONNECTORS]...
: Connectors to monitor
Options:
-
--refresh-interval INTEGER
: Refresh interval [default: 5] -
--help
: Show this message and exit.