diff --git a/backend/services/blockchain-service/Dockerfile b/backend/services/blockchain-service/Dockerfile
index e8d5ac47..4d8bec84 100644
--- a/backend/services/blockchain-service/Dockerfile
+++ b/backend/services/blockchain-service/Dockerfile
@@ -52,11 +52,11 @@ RUN DATABASE_URL="postgresql://user:pass@localhost:5432/db" npx prisma generate
 # Copy built files
 COPY --from=builder /app/dist ./dist
 
-# Create startup script that runs migrations before starting the app
+# Create startup script that syncs schema before starting the app
 RUN echo '#!/bin/sh\n\
 set -e\n\
-echo "Running database migrations..."\n\
-npx prisma migrate deploy || npx prisma db push --accept-data-loss\n\
+echo "Syncing database schema..."\n\
+npx prisma db push --skip-generate\n\
 echo "Starting application..."\n\
 exec node dist/main.js\n' > /app/start.sh && chmod +x /app/start.sh
 
diff --git a/backend/services/docker-compose.yml b/backend/services/docker-compose.yml
index 85615136..d446c53c 100644
--- a/backend/services/docker-compose.yml
+++ b/backend/services/docker-compose.yml
@@ -342,7 +342,7 @@ services:
       - REDIS_PORT=6379
       - REDIS_PASSWORD=${REDIS_PASSWORD:-}
       - REDIS_DB=5
-      - KAFKA_BROKERS=rwa-kafka:29092
+      - KAFKA_BROKERS=kafka:29092
       - KAFKA_CLIENT_ID=mpc-service
       - KAFKA_GROUP_ID=mpc-service-group
       # MPC System - 使用 Docker 网络内部地址
diff --git a/backend/services/mpc-service/src/infrastructure/messaging/kafka/event-publisher.service.ts b/backend/services/mpc-service/src/infrastructure/messaging/kafka/event-publisher.service.ts
index 8360b217..88bdffd2 100644
--- a/backend/services/mpc-service/src/infrastructure/messaging/kafka/event-publisher.service.ts
+++ b/backend/services/mpc-service/src/infrastructure/messaging/kafka/event-publisher.service.ts
@@ -73,13 +73,17 @@ export class EventPublisherService implements OnModuleInit, OnModuleDestroy {
     this.logger.log(`[PUBLISH] EventId: ${event.eventId}`);
     this.logger.log(`[PUBLISH] AggregateId: ${event.aggregateId}`);
 
+    // Merge extraPayload into payload if present (used by KeygenCompletedEvent etc.)
+    const extraPayload = (event as any).extraPayload || {};
+    const fullPayload = { ...event.payload, extraPayload };
+
     const messageValue = {
       eventId: event.eventId,
       eventType: event.eventType,
       occurredAt: event.occurredAt.toISOString(),
       aggregateId: event.aggregateId,
       aggregateType: event.aggregateType,
-      payload: event.payload,
+      payload: fullPayload,
     };
 
     this.logger.log(`[PUBLISH] Payload keys: ${Object.keys(event.payload).join(', ')}`);