diff --git a/server/kafka/src/index.ts b/server/kafka/src/index.ts
index a0015f3c3c..04474ef5f0 100644
--- a/server/kafka/src/index.ts
+++ b/server/kafka/src/index.ts
@@ -204,7 +204,10 @@ class PlatformQueueConsumerImpl implements ConsumerHandle {
       fromBegining?: boolean
     }
   ) {
-    this.cc = this.kafka.consumer({ groupId: `${getKafkaTopicId(this.topic, this.config)}-${groupId}` })
+    this.cc = this.kafka.consumer({
+      groupId: `${getKafkaTopicId(this.topic, this.config)}-${groupId}`,
+      allowAutoTopicCreation: true
+    })
 
     void this.start().catch((err) => {
       ctx.error('failed to consume', { err })