kafka-connect-manager 0.3.1

A tool to manage Apache Kafka Connect connectors and tasks using asyncio

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
• list: List all connectors
• status: Get status connector

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.