[BACK-2999] Add user_attribute table to users-source connector. (#349)

Author: lostlevels

charts/tidepool/Chart.yaml

@@ -1,7 +1,7 @@
 apiVersion: v2
 description: A Helm chart for Tidepool
 name: tidepool
-version: 0.24.5
+version: 0.24.6
 maintainers:
   - name: Todd Kazakov
     email: todd@tidepool.org

charts/tidepool/charts/kafka/templates/2-users-source-kafka-connector.yaml

@@ -27,11 +27,15 @@ spec:
     value.converter: 'org.apache.kafka.connect.json.JsonConverter'
     value.converter.schemas.enable: false
     snapshot.mode: {{ .Values.keycloak.snapshotMode }}
-    table.include.list: 'public.user_entity,public.user_role_mapping,public.keycloak_role'
-    transforms: 'filter'
+    table.include.list: 'public.user_entity,public.user_role_mapping,public.keycloak_role,public.user_attribute'
+    transforms: 'filter,filter_user_attr'
     transforms.filter.type: 'io.debezium.transforms.Filter'
     transforms.filter.language: 'jsr223.groovy'
     transforms.filter.topic.regex: '.+\.public.(user_entity|keycloak_role)'
     transforms.filter.condition: "value.op && (((value.op == 'r' || value.op == 'c' || value.op == 'u') && (value.after && value.after.realm_id && value.after.realm_id == '{{ $realm }}')) || (value.op == 'd'))"
+    transforms.filter_user_attr.type: 'io.debezium.transforms.Filter'
+    transforms.filter_user_attr.language: 'jsr223.groovy'
+    transforms.filter_user_attr.topic.regex: '.+\.public.(user_attribute)'
+    transforms.filter_user_attr.condition: "value.op && ((value.op == 'r' || value.op == 'c' || value.op == 'u') && value?.after?.name != null && value.after.name == 'terms_and_conditions')"
   tasksMax: 1
 {{- end }}