updated working example of spanner connector

Author: sionsmith

examples/custom-connect-gcp-connectors/confluent/source-topic.yaml

@@ -16,3 +16,22 @@ spec:
     endpoint: https://kafka.sandbox.svc.cluster.local:8090
   configs:
     cleanup.policy: "delete"
+---
+apiVersion: platform.confluent.io/v1beta1
+kind: KafkaTopic
+metadata:
+  name: sbs-kafka-test
+spec:
+  replicas: 3
+  partitionCount: 4
+  kafkaClusterRef:
+    name: kafka
+    namespace: sandbox
+  kafkaRest:
+    authentication:
+      type: bearer
+      bearer:
+        secretRef: rest-credential
+    endpoint: https://kafka.sandbox.svc.cluster.local:8090
+  configs:
+    cleanup.policy: "delete"

examples/custom-connect-gcp-connectors/rolebindings/connect/gcs-connect-rb.yaml

@@ -15,27 +15,14 @@ metadata:
   namespace: confluent
 spec:
   clustersScopeByIds:
-    connectClusterId: gcsconnect-cluster
+    connectClusterId: sandbox.gcsconnect
   principal:
     name: connect
     type: user
   role: SecurityAdmin
 ---
 apiVersion: platform.confluent.io/v1beta1
 kind: ConfluentRolebinding
-metadata:
-  name: gcsconnect-cluster-base-sysadmin
-  namespace: confluent
-spec:
-  clustersScopeByIds:
-    connectClusterId: gcsconnect-cluster
-  principal:
-    name: connect
-    type: user
-  role: SystemAdmin
----
-apiVersion: platform.confluent.io/v1beta1
-kind: ConfluentRolebinding
 metadata:
   name: gcsconnect-resources-base
   namespace: confluent
@@ -65,6 +52,9 @@ spec:
     name: connect
     type: user
   resourcePatterns:
+    - name: sbs-kafka-test
+      patternType: LITERAL
+      resourceType: Topic
     - name: topic-in-source
       patternType: LITERAL
       resourceType: Topic

examples/custom-connect-gcp-connectors/spanner-sink.json

@@ -2,7 +2,7 @@
   "name": "spanner-sink-connector",
   "connector.class": "io.confluent.connect.gcp.spanner.SpannerSinkConnector",
   "tasks.max": "1",
-  "topics": "SBSKAFTEST",
+  "topics": "sbs-kafka-test",
   "gcp.spanner.credentials.path": "/mnt/secrets/gcs-service-account/service-account.json",
   "gcp.spanner.instance.id": "sbs-kaf-spanner",
   "gcp.spanner.database.id": "sbs-kaf-spanner-db",