A tool to manage Apache Kafka Connect connectors and tasks using asyncio
Project description
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 connectorsstatus
: Get status connectorupdate
: Update connector configurationwatch
: 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.
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for kafka_connect_manager-0.5.0.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | a370529a6d8c95f05ded921f6bd3b2e4423471682b37fbd09e80ce415f05f6a6 |
|
MD5 | 5ea5eebfa5499e17e345ee1284db899e |
|
BLAKE2b-256 | c2cc5e42ce2f3297c1c133ad4ca4de9a2dae8d0301b7971fd09e02709478813a |
Close
Hashes for kafka_connect_manager-0.5.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | a4b7cc756b960224c32132e0f538fd5c1f1c33f332a82b634b63162f5a3d0d65 |
|
MD5 | b7624dcf37d6314c2898ebdeaf7359b5 |
|
BLAKE2b-256 | 1d5c103aafd6afdaf0e35b89df590020b8d0fa5c720e474a2b44b5659095b8c3 |