From 2b63c2beb5e0401bbcccb4ba21c3fb60cbadd367 Mon Sep 17 00:00:00 2001
From: Sipke Schoorstra <sipkeschoorstra@outlook.com>
Date: Thu, 5 Dec 2024 09:31:41 +0100
Subject: [PATCH] Add Kafka consumers + producers to reference project

---
 src/apps/Elsa.Server.Web/appsettings.json | 35 +++++++++++++++++++++++
 1 file changed, 35 insertions(+)

diff --git a/src/apps/Elsa.Server.Web/appsettings.json b/src/apps/Elsa.Server.Web/appsettings.json
index 889afc59e..ea33ad3b9 100644
--- a/src/apps/Elsa.Server.Web/appsettings.json
+++ b/src/apps/Elsa.Server.Web/appsettings.json
@@ -206,6 +206,41 @@
       }
     ]
   },
+  "Kafka": {
+    "Topics": [
+      {
+        "Id": "topic-1",
+        "Name": "topic-1"
+      },
+      {
+        "Id": "topic-2",
+        "Name": "topic-2"
+      }
+    ],
+    "Producers": [
+      {
+        "Id": "producer-1",
+        "Name": "Producer 1",
+        "FactoryType": "Elsa.Kafka.Factories.GenericProducerFactory`2[[System.String, System.Private.CoreLib], [Elsa.Server.Web.Messages.OrderReceived, Elsa.Server.Web]], Elsa.Kafka",
+        "Config": {
+          "BootstrapServers": "localhost:9092"
+        }
+      }
+    ],
+    "Consumers": [
+      {
+        "Id": "consumer-1",
+        "Name": "Consumer 1",
+        "FactoryType": "Elsa.Kafka.Factories.GenericConsumerFactory`2[[System.String, System.Private.CoreLib], [Elsa.Server.Web.Messages.OrderReceived, Elsa.Server.Web]], Elsa.Kafka",
+        "Config": {
+          "BootstrapServers": "localhost:9092",
+          "GroupId": "group-1",
+          "AutoOffsetReset": "earliest",
+          "EnableAutoCommit": "true"
+        }
+      }
+    ]
+  },
   "Secrets": {
     "Management": {
       "SweepInterval": "04:00:00"