|
| 1 | +apiVersion: v1 |
| 2 | +kind: ServiceAccount |
| 3 | +metadata: |
| 4 | + name: kafka-user-secret-syncer |
| 5 | + namespace: backend |
| 6 | + annotations: |
| 7 | + argocd.argoproj.io/sync-wave: "-1" |
| 8 | +--- |
| 9 | +apiVersion: rbac.authorization.k8s.io/v1 |
| 10 | +kind: ClusterRole |
| 11 | +metadata: |
| 12 | + name: kafka-user-secret-syncer-role |
| 13 | + annotations: |
| 14 | + argocd.argoproj.io/sync-wave: "-1" |
| 15 | +rules: |
| 16 | + - verbs: |
| 17 | + - get |
| 18 | + - list |
| 19 | + - create |
| 20 | + - update |
| 21 | + - patch |
| 22 | + apiGroups: [""] |
| 23 | + resources: ["secrets"] |
| 24 | +--- |
| 25 | +apiVersion: rbac.authorization.k8s.io/v1 |
| 26 | +kind: ClusterRoleBinding |
| 27 | +metadata: |
| 28 | + name: kafka-user-secret-syncer-backend |
| 29 | + annotations: |
| 30 | + argocd.argoproj.io/sync-wave: "-1" |
| 31 | +subjects: |
| 32 | + - kind: ServiceAccount |
| 33 | + name: kafka-user-secret-syncer |
| 34 | + namespace: backend |
| 35 | +roleRef: |
| 36 | + apiGroup: rbac.authorization.k8s.io |
| 37 | + kind: ClusterRole |
| 38 | + name: kafka-user-secret-syncer-role |
| 39 | +--- |
| 40 | +# Kafka User Secret backend 네임스페이스로 이동 |
| 41 | +apiVersion: batch/v1 |
| 42 | +kind: CronJob |
| 43 | +metadata: |
| 44 | + name: sync-kafka-user-secret |
| 45 | + namespace: backend |
| 46 | + annotations: |
| 47 | + argocd.argoproj.io/hook: PostSync |
| 48 | + argocd.argoproj.io/hook-delete-policy: BeforeHookCreation |
| 49 | +spec: |
| 50 | + schedule: "*/10 * * * *" |
| 51 | + concurrencyPolicy: Forbid |
| 52 | + jobTemplate: |
| 53 | + spec: |
| 54 | + backoffLimit: 10 |
| 55 | + template: |
| 56 | + spec: |
| 57 | + serviceAccountName: kafka-user-secret-syncer |
| 58 | + restartPolicy: OnFailure |
| 59 | + containers: |
| 60 | + - name: cluster-init |
| 61 | + image: bitnami/kubectl:latest |
| 62 | + command: |
| 63 | + - /bin/sh |
| 64 | + - -c |
| 65 | + - | |
| 66 | + set -e |
| 67 | + |
| 68 | + # KafkaUser 등록으로 같이 생성된 KafkaUser Secret |
| 69 | + SECRETS=( |
| 70 | + "backend-core-kafka-user:kafka:backend" |
| 71 | + "backend-story-kafka-user:kafka:backend" |
| 72 | + ) |
| 73 | + |
| 74 | + for secret_info in "${SECRETS[@]}"; do |
| 75 | + IFS=':' read -r secret_name src_ns dst_ns <<< "$secret_info" |
| 76 | + |
| 77 | + echo "Syncing $secret_name from $src_ns to $dst_ns..." |
| 78 | + |
| 79 | + kubectl get secret "$secret_name" -n "$src_ns" -o json \ |
| 80 | + | jq 'del(.metadata.namespace, .metadata.resourceVersion, .metadata.uid, .metadata.creationTimestamp, .metadata.selfLink, .metadata.ownerReferences)' \ |
| 81 | + | kubectl apply -n "$dst_ns" -f - |
| 82 | + done |
0 commit comments