diff --git a/apps/order-service/src/kafka/kafka.producer.service.ts b/apps/order-service/src/kafka/kafka.producer.service.ts
index 00d8e10..c921b1a 100644
--- a/apps/order-service/src/kafka/kafka.producer.service.ts
+++ b/apps/order-service/src/kafka/kafka.producer.service.ts
@@ -1,13 +1,16 @@
 import { Inject, Injectable } from "@nestjs/common";
 import { ClientKafka } from "@nestjs/microservices";
 import { KafkaMessage } from "./KafkaMessage";
-import { KafkaTopics } from "./topics";
+import { MyMessageBrokerTopics } from "./topics";
 
 @Injectable()
 export class KafkaProducerService {
   constructor(@Inject("KAFKA_CLIENT") private kafkaClient: ClientKafka) {}
 
-  async emitMessage(topic: KafkaTopics, message: KafkaMessage): Promise<void> {
+  async emitMessage(
+    topic: MyMessageBrokerTopics,
+    message: KafkaMessage
+  ): Promise<void> {
     return await new Promise((resolve, reject) => {
       this.kafkaClient.emit(topic, message).subscribe({
         error: (err: Error) => {