mdwajid095/kcctl
kcctl is a tool like kubectl, specially design for kafka connect. kcctl is over ubi-minimal:8.6
79
Pull and run the container/pod: docker pull mdwajid095/kcctl:v1.2
Go inside the container/pod: kubectl exec -it kcctl bash -n dev
Before doing any operations with connectors or replicators. We have to set the context. To set context, we have to execute the below command with correct environment internal url of connect or replicator pod.
#to setup for connectors
kcctl config set-context local --cluster https://connect.dev.svc.cluster.local:8083
#To setup for replicators kcctl config set-context local --cluster https://replicator.dev.svc.cluster.local:8083
Operations with connectors and replicators Below are the operations, which we can perform on connectors or replicators to do all sorts of CRUD operation.
And these are the few important command of operations.
#to list the connectors or replicators
kcctl -Djavax.net.ssl.trustStore=/mnt/secrets/kafka-internal-truststore.jks -Djavax.net.ssl.trustStorePassword=mystorepassword -Djavax.net.ssl.trustStoreProvider=SUN get connectors
#To upload the connectors or replicators
kcctl -Djavax.net.ssl.trustStore=/mnt/secrets/kafka-internal-truststore.jks -Djavax.net.ssl.trustStorePassword=mystorepassword -Djavax.net.ssl.trustStoreProvider=SUN apply --file connectorFile.json
#To describe the connectors or replicators
kcctl -Djavax.net.ssl.trustStore=/mnt/secrets/kafka-internal-truststore.jks -Djavax.net.ssl.trustStorePassword=mystorepassword -Djavax.net.ssl.trustStoreProvider=SUN describe connector connectorName
#To delete the connectors or replicators
kcctl -Djavax.net.ssl.trustStore=/mnt/secrets/kafka-internal-truststore.jks -Djavax.net.ssl.trustStorePassword=mystorepassword -Djavax.net.ssl.trustStoreProvider=SUN delete connetotName
docker pull mdwajid095/kcctl