From 30aa11c6c645a76532e303763f64c695566f92e1 Mon Sep 17 00:00:00 2001
From: hailin <hailin.zhao@gdzx.xyz>
Date: Tue, 9 Dec 2025 22:31:12 -0800
Subject: [PATCH] fix(referral): fix EventAckMessage type casting
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Cast ackMessage to Record<string, unknown> for KafkaService compatibility.

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
---
 .../src/infrastructure/kafka/event-ack.publisher.ts           | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/backend/services/referral-service/src/infrastructure/kafka/event-ack.publisher.ts b/backend/services/referral-service/src/infrastructure/kafka/event-ack.publisher.ts
index d9962bd9..f2fb1fc9 100644
--- a/backend/services/referral-service/src/infrastructure/kafka/event-ack.publisher.ts
+++ b/backend/services/referral-service/src/infrastructure/kafka/event-ack.publisher.ts
@@ -48,7 +48,7 @@ export class EventAckPublisher {
       await this.kafkaService.publish({
         topic: 'planting.events.ack',
         key: eventId,
-        value: ackMessage,
+        value: ackMessage as unknown as Record<string, unknown>,
       });
 
       this.logger.log(`[ACK] ✓ Sent success confirmation for event ${eventId} (${eventType})`);
@@ -74,7 +74,7 @@ export class EventAckPublisher {
       await this.kafkaService.publish({
         topic: 'planting.events.ack',
         key: eventId,
-        value: ackMessage,
+        value: ackMessage as unknown as Record<string, unknown>,
       });
 
       this.logger.warn(`[ACK] ✗ Sent failure confirmation for event ${eventId}: ${errorMessage}`);