Apache Kafka

Connect Commands

Kafka Connect provides scalable data integration with databases and other systems. Manage connectors via REST API.

10 commands

Pro Tips

Check connector and task status regularly to detect failures early.

Store connector configs in JSON files for version control.

Common Mistakes

Restarting connectors may cause brief data interruption.

Commands

List connectors

$ curl -s localhost:8083/connectors | jq

List all connectors.

Connector status

$ curl -s localhost:8083/connectors/my-connector/status | jq

Get connector status.

Create connector

$ curl -X POST -H 'Content-Type: application/json' --data @connector.json localhost:8083/connectors

Create connector from config file.

Delete connector

$ curl -X DELETE localhost:8083/connectors/my-connector

Delete a connector.

Restart connector

$ curl -X POST localhost:8083/connectors/my-connector/restart

Restart a connector.

Pause connector

$ curl -X PUT localhost:8083/connectors/my-connector/pause

Pause a connector.

Run standalone connector

$ kafka-connect/bin/connect-standalone.sh config/connect-standalone.properties connector.properties

Start Kafka Connect in standalone mode.

Create connector via REST

$ curl -X POST http://localhost:8083/connectors -H "Content-Type: application/json" -d @connector-config.json

Create connector using REST API with config file.

Check connector status

$ curl http://localhost:8083/connectors/<name>/status

Check status of specific connector.

Delete connector

$ curl -X DELETE http://localhost:8083/connectors/<name>

Remove a connector via REST API.

Apache Kafka

Connect Commands

Kafka Connect provides scalable data integration with databases and other systems. Manage connectors via REST API.

10 commands

Pro Tips

Check connector and task status regularly to detect failures early.

Store connector configs in JSON files for version control.

Common Mistakes

Restarting connectors may cause brief data interruption.

Commands

List connectors

$ curl -s localhost:8083/connectors | jq

List all connectors.

Connector status

$ curl -s localhost:8083/connectors/my-connector/status | jq

Get connector status.

Create connector

$ curl -X POST -H 'Content-Type: application/json' --data @connector.json localhost:8083/connectors

Create connector from config file.

Delete connector

$ curl -X DELETE localhost:8083/connectors/my-connector

Delete a connector.

Restart connector

$ curl -X POST localhost:8083/connectors/my-connector/restart

Restart a connector.

Pause connector

$ curl -X PUT localhost:8083/connectors/my-connector/pause

Pause a connector.

Run standalone connector

$ kafka-connect/bin/connect-standalone.sh config/connect-standalone.properties connector.properties

Start Kafka Connect in standalone mode.

Create connector via REST

$ curl -X POST http://localhost:8083/connectors -H "Content-Type: application/json" -d @connector-config.json

Create connector using REST API with config file.

Check connector status

$ curl http://localhost:8083/connectors/<name>/status

Check status of specific connector.

Delete connector

$ curl -X DELETE http://localhost:8083/connectors/<name>

Remove a connector via REST API.