[Kafka-connect] A few APIs are helpful in Kafka-connect.

list topic:

docker exec kafkacat kafkacat -b broker:29092 -L -J | jq '.topics[].topic'|sort

List các connector:

curl -s "http://localhost:8083/connectors?expand=info&expand=status" | \
       jq '. | to_entries[] | [ .value.info.type, .key, .value.status.connector.state,.value.status.tasks[].state,.value.info.config."connector.class"]|join(":|:")' | \
       column -s : -t| sed 's/\"//g'| sort

show status connector:

curl -s "http://localhost:8083/connectors/sink-jdbc-mysql-00/status"| \
    jq -c -M '[.name,.tasks[].state]'

show config connector:

curl -i -X GET -H "Accept:application/json" \
    -H  "Content-Type:application/json" http://localhost:8083/connectors/sink-jdbc-mysql-00/config

delete connector

curl -i -X DELETE -H "Accept:application/json" \
    -H  "Content-Type:application/json" http://localhost:8083/connectors/sink-jdbc-mysql-00

show error or exception a task of a connector:

curl -s "http://localhost:8083/connectors/sink-jdbc-mysql-00/status"| jq '.tasks[0].trace'