fix: KafkaProducerFactory not init from decorator (#4271)

midwayjs · Jan 25, 2025 · 606d76d · 606d76d
1 parent 32458b2
commit 606d76d
Showing 1 changed file with 7 additions and 2 deletions.
diff --git 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);
+  }
+}