fix(microservices): reorder kafka config assigment

packages/microservices/server/server-kafka.ts

@@ -107,11 +107,11 @@ export class ServerKafka extends Server implements CustomTransportStrategy {
 
   public createClient<T = any>(): T {
     return new kafkaPackage.Kafka(
-      Object.assign(this.options.client || {}, {
-        clientId: this.clientId,
-        brokers: this.brokers,
-        logCreator: KafkaLogger.bind(null, this.logger),
-      }) as KafkaConfig,
+      Object.assign(
+        { logCreator: KafkaLogger.bind(null, this.logger) },
+        this.options.client,
+        { clientId: this.clientId, brokers: this.brokers }
+      ) as KafkaConfig,
     );
   }
 

packages/microservices/test/server/server-kafka.spec.ts

@@ -425,4 +425,24 @@ describe('ServerKafka', () => {
       ).to.be.true;
     });
   });
+
+  describe('createClient', () => {
+    it('should accept a custom logCreator in client options', () => {
+      const logCreatorSpy = sinon.spy(() => 'test');
+      const logCreator = () => logCreatorSpy;
+
+      server = new ServerKafka({
+        client: {
+          brokers: [],
+          logCreator,
+        },
+      });
+
+      const logger = server.createClient().logger();
+
+      logger.info({ namespace: '', level: 1, log: 'test' });
+
+      expect(logCreatorSpy.called).to.be.true;
+    })
+  })
 });