From d4216a6e9ec86a2b8a1c6f6ca98f6d7628d0216a Mon Sep 17 00:00:00 2001
From: Denis Bykhov <bykhov.denis@gmail.com>
Date: Tue, 5 Aug 2025 07:17:06 +0500
Subject: [PATCH] Create process topic (#9638)

---
 server/kafka/src/index.ts | 1 +
 1 file changed, 1 insertion(+)

diff --git a/server/kafka/src/index.ts b/server/kafka/src/index.ts
index 39686ee093..70fb0fe519 100644
--- a/server/kafka/src/index.ts
+++ b/server/kafka/src/index.ts
@@ -133,6 +133,7 @@ class PlatformQueueImpl implements PlatformQueue {
     await this.checkCreateTopic(QueueTopic.Fulltext, topics, 1)
     await this.checkCreateTopic(QueueTopic.Workspace, topics, 1)
     await this.checkCreateTopic(QueueTopic.Users, topics, 1)
+    await this.checkCreateTopic(QueueTopic.Process, topics, 1)
   }
 
   async checkDeleteTopic (topic: QueueTopic | string, topics: Set<string>): Promise<void> {