Method sendRaw

worker/src/adapters/kafka-nodeio.adapter.ts:206–212

(key: string, message: string)

  }

  private async sendRaw(key: string, message: string): Promise<void> {
    await this.connectPromise;
    await this.producer.send({
      topic: this.config.topic,
      messages: [{ key, value: message }],
    });
  }
}