-
Notifications
You must be signed in to change notification settings - Fork 20
/
teardown_connectors.sh
executable file
·31 lines (23 loc) · 1.28 KB
/
teardown_connectors.sh
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
#!/bin/bash
# Source the .env file
source .env
# Use confluent environment
confluent login --save
export CCLOUD_ENV_ID=$(confluent environment list -o json \
| jq -r '.[] | select(.name | contains('\"${CCLOUD_ENV_NAME:-Demo_Database_Modernization}\"')) | .id')
confluent env use $CCLOUD_ENV_ID
# Use kafka cluster
export CCLOUD_CLUSTER_ID=$(confluent kafka cluster list -o json \
| jq -r '.[] | select(.name | contains('\"${CCLOUD_CLUSTER_NAME:-demo_kafka_cluster}\"')) | .id')
confluent kafka cluster use $CCLOUD_CLUSTER_ID
# Get cluster bootstrap endpoint
export CCLOUD_BOOTSTRAP_ENDPOINT=$(confluent kafka cluster describe -o json | jq -r .endpoint)
# Get the ID for all connectors
oracle_id=$(confluent connect cluster list -o json | jq -r '.[] | select(.name | contains ("OracleCdcSourceConnector_0")) | .id')
rabbitmq_id=$(confluent connect cluster list -o json | jq -r '.[] | select(.name | contains ("RabbitMQSourceConnector_0")) | .id')
mongodb_id=$(confluent connect cluster list -o json | jq -r '.[] | select(.name | contains ("MongoDbAtlasSinkConnector_0")) | .id')
# Delete all connectors
echo "Deleting connectors..."
confluent connect cluster delete --force "$oracle_id"
confluent connect cluster delete --force "$rabbitmq_id"
confluent connect cluster delete --force "$mongodb_id"