Create process topic (#9638)

BykhovDenis · web-flow · commit d4216a6e9ec8 · 2025-08-05T09:17:06.000+07:00
diff --git 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> {

Original file line number	Diff line number	Diff line change
`@@ -133,6 +133,7 @@ class PlatformQueueImpl implements PlatformQueue {`
`133`	`133`	`await this.checkCreateTopic(QueueTopic.Fulltext, topics, 1)`
`134`	`134`	`await this.checkCreateTopic(QueueTopic.Workspace, topics, 1)`
`135`	`135`	`await this.checkCreateTopic(QueueTopic.Users, topics, 1)`
	`136`	`+ await this.checkCreateTopic(QueueTopic.Process, topics, 1)`
`136`	`137`	`}`
`137`	`138`
`138`	`139`	`async checkDeleteTopic (topic: QueueTopic \| string, topics: Set<string>): Promise<void> {`