From 5cbdb095271710823eeb8024874fef913d7506a7 Mon Sep 17 00:00:00 2001
From: Ivan Yourshaw <39739503+iyourshaw@users.noreply.github.com>
Date: Sun, 27 Jul 2025 16:26:22 -0600
Subject: [PATCH] rtcm topics

---
 jikkou/kafka-connectors-values.yaml | 12 ++++++++++++
 jikkou/kafka-topics-values.yaml     |  1 +
 mongo/create_indexes.js             |  2 +-
 3 files changed, 14 insertions(+), 1 deletion(-)

diff --git a/jikkou/kafka-connectors-values.yaml b/jikkou/kafka-connectors-values.yaml
index 94e8861..1ae0fbd 100644
--- a/jikkou/kafka-connectors-values.yaml
+++ b/jikkou/kafka-connectors-values.yaml
@@ -249,6 +249,14 @@ apps:
         collectionName: CmRevocableEnabledLaneAlignmentEvent
         useTimestamp: true
         timestampField: eventGeneratedAt
+      - topicName: topic.CmRtcmBroadcastRateEvent
+        collectionName: CmRtcmBroadcastRateEvent
+        useTimestamp: true
+        timestampField: eventGeneratedAt
+      - topicName: topic.CmRtcmMinimumDataEvent
+        collectionName: CmRtcmMinimumDataEvent
+        useTimestamp: true
+        timestampField: eventGeneratedAt
       - topicName: topic.CmSpatMinimumDataEventAggregation
         collectionName: CmSpatMinimumDataEventAggregation
         generateTimestamp: true
@@ -293,6 +301,10 @@ apps:
         collectionName: CmRevocableEnabledLaneAlignmentEventAggregation
         generateTimestamp: true
         timestampField: eventGeneratedAt
+      - topicName: topic.CmRtcmMinimumDataEventAggregation
+        collectionName: CmRtcmMinimumDataEventAggregation
+        generateTimestamp: true
+        timestampField: eventGeneratedAt
 
 
 
diff --git a/jikkou/kafka-topics-values.yaml b/jikkou/kafka-topics-values.yaml
index 8c9732a..625969b 100644
--- a/jikkou/kafka-topics-values.yaml
+++ b/jikkou/kafka-topics-values.yaml
@@ -87,6 +87,7 @@ apps:
       - topic.ProcessedMap
       - topic.ProcessedMapWKT
       - topic.ProcessedBsm
+      - topic.ProcessedRtcm
     tableTopics: {}
     customTopics: {}
   conflictmonitor:
diff --git a/mongo/create_indexes.js b/mongo/create_indexes.js
index 82b8bea..5d0cf41 100644
--- a/mongo/create_indexes.js
+++ b/mongo/create_indexes.js
@@ -89,7 +89,7 @@ const odeCollections = [
 const geoJsonConverterCollections = [
     {name: "ProcessedMap", ttlField: "recordGeneratedAt", timeField: "properties.timeStamp", intersectionField: "properties.intersectionId", expireTime: expireSeconds},
     {name: "ProcessedSpat", ttlField: "recordGeneratedAt", timeField: "utcTimeStamp", intersectionField: "intersectionId", expireTime: expireSeconds},
-    {name: "ProcessedBsm", ttlField: "recordGeneratedAt", timeField: "timeStamp", geoSpatialField: "geometry.coordinates", expireTime: expireSeconds},
+    {name: "ProcessedBsm", ttlField: "recordGeneratedAt", timeField: "timeStamp", geoSpatialField: "geometry.coordinates", expireTime: expireSeconds}
 ];