Skip to content

Commit

Permalink
Add lsstcomcam-alerts as a topic to the alert broker
Browse files Browse the repository at this point in the history
  • Loading branch information
bsmartradio authored and erinleighh committed Oct 25, 2024
1 parent 2ae7496 commit 28f2c09
Show file tree
Hide file tree
Showing 2 changed files with 25 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -93,4 +93,24 @@ spec:
# timestamp instead
message.timestamp.type: 'LogAppendTime'
partitions: {{ .Values.latissTopicPartitions }}
replicas: {{ .Values.latissTopicReplicas }}
replicas: {{ .Values.latissTopicReplicas }}
---
apiVersion: "kafka.strimzi.io/{{ .Values.strimziAPIVersion }}"
kind: KafkaTopic
metadata:
labels:
strimzi.io/cluster: "{{ .Values.clusterName }}"
name: "{{ .Values.comcamTopicName}}"
spec:
config:
cleanup.policy: "delete"
retention.ms: {{ .Values.maxMillisecondsRetained }} # 7 days
retention.bytes: {{ .Values.maxBytesRetained }}
compression.type: {{ .Values.topicCompression }}
# The default timestamp is the creation time of the alert.
# To get the ingestion rate, we need this to be the log
# append time, and the header will contain the producer
# timestamp instead
message.timestamp.type: 'LogAppendTime'
partitions: {{ .Values.comcamTopicPartitions }}
replicas: {{ .Values.comcamTopicReplicas }}
Original file line number Diff line number Diff line change
Expand Up @@ -121,6 +121,10 @@ alert-stream-broker:
latissTopicPartitions: 45
latissTopicReplicas: 1

comcamTopicName: lsstcomcam-alerts
comcamTopicPartitions: 45
comcamTopicReplicas: 1

# Compression set to snappy to balance alert packet compression speed and size.
topicCompression: snappy

Expand Down

0 comments on commit 28f2c09

Please sign in to comment.