fix: kafka debug level fix

SystemConsultantGroup · Oct 18, 2024 · f46bf0f · f46bf0f
1 parent b8c47e1
commit f46bf0f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/config/kafka/kafka.service.ts b/src/config/kafka/kafka.service.ts
@@ -14,7 +14,7 @@ export class KafkaProducer implements OnModuleInit, OnModuleDestroy {
         "kafka-controller-1.kafka-controller-headless.kafka.svc.cluster.local:9092",
         "kafka-controller-2.kafka-controller-headless.kafka.svc.cluster.local:9092",
       ],
-      logLevel: logLevel.INFO,
+      logLevel: logLevel.DEBUG,
       retry: {
         initialRetryTime: 100,
         retries: 10,

diff --git a/src/modules/reviews/reviews.service.ts b/src/modules/reviews/reviews.service.ts
@@ -273,7 +273,7 @@ export class ReviewsService {
 
           const key = v1();
           const createdAt = new Date();
-          await this.kafkaProducer.sendMessage("pdf-topic-dev", reviewId, formatHtml, {
+          await this.kafkaProducer.sendMessage("pdf-topic-dev", JSON.stringify(reviewId), formatHtml, {
             originalName: studentName + "_" + fileName.replace("_양식.html", ".pdf"),
             uuid: key,
           });
@@ -341,7 +341,7 @@ export class ReviewsService {
           //     "application/pdf"
           //   );
           // });
-          await this.kafkaProducer.sendMessage("pdf-topic-dev", reviewId.toString(), formatHtml, {
+          await this.kafkaProducer.sendMessage("pdf-topic-dev", JSON.stringify(reviewId), formatHtml, {
             originalName: studentName + "_" + professorName + "_" + fileName.replace("_양식.html", ".pdf"),
             uuid: key,
           });