mdwajid095/kcctl

By mdwajid095

Updated over 2 years ago

kcctl is a tool like kubectl, specially design for kafka connect. kcctl is over ubi-minimal:8.6

Image
Message Queues
2

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 Command

docker pull mdwajid095/kcctl