mdwajid095/kcctl repository overview

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