Allow auto topic creation in consumer (#8529)

Signed-off-by: Andrey Sobolev <haiodo@gmail.com>
This commit is contained in:
Andrey Sobolev
2025-04-11 10:43:33 +07:00
committed by GitHub
parent bc5a88ca80
commit fb8ce8ad65
+4 -1
View File
@@ -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 })