Skip to content

Commit 5a59b4e

Browse files
committed
use CDC to publish alerts to a kafka topic
These alerts will be used to trigger push notifications in support of the care partner alerting app. BACK-2504
1 parent 7a0f374 commit 5a59b4e

File tree

1 file changed

+26
-0
lines changed

1 file changed

+26
-0
lines changed
Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
{{ if .Values.global.kafka.connect.enabled }}
2+
apiVersion: kafka.strimzi.io/v1beta2
3+
kind: KafkaConnector
4+
metadata:
5+
labels:
6+
app: alerts-source
7+
strimzi.io/cluster: {{ .Release.Namespace }}-{{ .Values.global.kafka.connect.clusterName }}
8+
name: alerts-source
9+
namespace: {{ .Release.Namespace }}
10+
spec:
11+
class: com.mongodb.kafka.connect.MongoSourceConnector
12+
config:
13+
change.stream.full.document: updateLookup
14+
collection: alerts
15+
connection.uri: {{ .Values.global.kafka.connect.mongoConnectionUri }}
16+
copy.existing: true
17+
database: data
18+
key.converter: org.apache.kafka.connect.json.JsonConverter
19+
key.converter.schemas.enable: false
20+
topic.prefix: {{ .Release.Namespace }}
21+
value.converter: org.apache.kafka.connect.json.JsonConverter
22+
value.converter.schemas.enable: false
23+
heartbeat.interval.ms: {{ .Values.global.kafka.connect.mongoHeartbeatIntervalMs }}
24+
heartbeat.topic.name: {{ .Release.Namespace }}-{{ .Values.global.kafka.connect.clusterName }}-heartbeat
25+
tasksMax: {{ .Values.global.kafka.connect.sourceTasksMax | int }}
26+
{{- end }}

0 commit comments

Comments
 (0)