Improve newrelic transaction name (#307)

* Fix docker conflicts with Kafka

* Improve newrelic transaction name

* release prepare

Author: CarlosGamero

docker-compose.yml

@@ -39,7 +39,6 @@ services:
 
   kafka:
     image: apache/kafka:3.7.1
-    container_name: kafka
     ports:
       - 9092:9092
     environment:
@@ -59,7 +58,6 @@ services:
     restart: on-failure
 
   kafka-ui:
-    container_name: kafka-ui
     image: provectuslabs/kafka-ui:latest
     ports:
       - 8080:8080

packages/kafka/lib/AbstractKafkaConsumer.ts

@@ -258,7 +258,7 @@ export abstract class AbstractKafkaConsumer<
   private buildTransactionName(message: Message<string, object, string, string>) {
     const messageType = this.resolveMessageType(message.value)
 
-    let name = `kafka:${message.topic}`
+    let name = `kafka:${this.constructor.name}:${message.topic}`
     if (messageType?.trim().length) name += `:${messageType.trim()}`
 
     return name

packages/kafka/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@message-queue-toolkit/kafka",
-    "version": "0.2.1",
+    "version": "0.2.2",
     "engines": {
         "node": ">= 22.14.0"
     },

packages/kafka/test/consumer/PermissionConsumer.spec.ts

@@ -308,11 +308,17 @@ describe('PermissionConsumer', () => {
 
       // Then
       await consumer.handlerSpy.waitForMessageWithId('1', 'consumed')
-      expect(startTransactionSpy).toHaveBeenCalledWith('kafka:permission-general:added', '1')
+      expect(startTransactionSpy).toHaveBeenCalledWith(
+        'kafka:PermissionConsumer:permission-general:added',
+        '1',
+      )
       expect(stopTransactionSpy).toHaveBeenCalledWith('1')
 
       await consumer.handlerSpy.waitForMessageWithId('2', 'consumed')
-      expect(startTransactionSpy).toHaveBeenCalledWith('kafka:permission-general', '2')
+      expect(startTransactionSpy).toHaveBeenCalledWith(
+        'kafka:PermissionConsumer:permission-general',
+        '2',
+      )
       expect(stopTransactionSpy).toHaveBeenCalledWith('2')
     })