Skip to content

Commit 52b6398

Browse files
authored
feat: Kafka minor log improvement (#339)
* Minor log improvement in Kafka consumer * Release prepare * Adding back log prop
1 parent 1bc5dc4 commit 52b6398

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

packages/kafka/lib/AbstractKafkaConsumer.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -478,6 +478,7 @@ export abstract class AbstractKafkaConsumer<
478478
reqId,
479479
logger: this.logger.child({
480480
'x-request-id': reqId,
481+
origin: this.constructor.name,
481482
topic: message.topic,
482483
messageKey: message.key,
483484
}),

packages/kafka/package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@message-queue-toolkit/kafka",
3-
"version": "0.7.1",
3+
"version": "0.7.2",
44
"engines": {
55
"node": ">= 22.14.0"
66
},

0 commit comments

Comments
 (0)