From 606d76d7f528c58668d6dfd61ff8306eb7560dcf Mon Sep 17 00:00:00 2001
From: Harry Chen <czy88840616@gmail.com>
Date: Sat, 25 Jan 2025 20:32:37 +0800
Subject: [PATCH] fix: KafkaProducerFactory not init from decorator (#4271)

---
 packages/kafka/src/configuration.ts | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/packages/kafka/src/configuration.ts b/packages/kafka/src/configuration.ts
index d148ac3bd0b..508ba16a92e 100644
--- a/packages/kafka/src/configuration.ts
+++ b/packages/kafka/src/configuration.ts
@@ -1,4 +1,5 @@
-import { Configuration } from '@midwayjs/core';
+import { Configuration, IMidwayContainer } from '@midwayjs/core';
+import { KafkaProducerFactory } from './service';
 
 @Configuration({
   namespace: 'kafka',
@@ -19,4 +20,8 @@ import { Configuration } from '@midwayjs/core';
     },
   ],
 })
-export class KafkaConfiguration {}
+export class KafkaConfiguration {
+  async onReady(container: IMidwayContainer) {
+    await container.getAsync(KafkaProducerFactory);
+  }
+}