diff --git a/src/kafka/kafka.service.ts b/src/kafka/kafka.service.ts index 0df56fe..491a90d 100644 --- a/src/kafka/kafka.service.ts +++ b/src/kafka/kafka.service.ts @@ -38,10 +38,10 @@ export class KafkaService implements OnModuleInit, OnModuleDestroy { } async onModuleInit() { - await this.consumer.connect(); - console.log('connected'); - await this.consumer.subscribe({ topic: this.topic, fromBeginning: false }); - console.log('subsribed'); + // await this.consumer.connect(); + // console.log('connected'); + // await this.consumer.subscribe({ topic: this.topic, fromBeginning: false }); + // console.log('subsribed'); // await this.consumer // .run({ // autoCommit: false, diff --git a/src/puppeteer/puppeteer.service.ts b/src/puppeteer/puppeteer.service.ts index 04b9c39..10d9b82 100644 --- a/src/puppeteer/puppeteer.service.ts +++ b/src/puppeteer/puppeteer.service.ts @@ -8,8 +8,8 @@ export class PuppeteerService implements OnModuleInit, OnModuleDestroy { async onModuleInit() { this.browser = await puppeteer.launch({ + headless: true, executablePath: '/usr/bin/chromium-browser', - protocolTimeout: 999_999, args: [ '--no-sandbox', '--disable-dev-shm-usage',