Skip to content
This repository was archived by the owner on Oct 31, 2024. It is now read-only.

Commit 459790a

Browse files
authored
fix(kafkajs): Support prerelease versions (#223)
1 parent 8d42dac commit 459790a

File tree

1 file changed

+4
-6
lines changed

1 file changed

+4
-6
lines changed

packages/instrumentation-kafkajs/src/kafkajs.ts

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -53,12 +53,10 @@ export class KafkaJsInstrumentation extends InstrumentationBase<typeof kafkaJs>
5353
}
5454

5555
protected init(): InstrumentationModuleDefinition<typeof kafkaJs> {
56-
const module = new InstrumentationNodeModuleDefinition<typeof kafkaJs>(
57-
KafkaJsInstrumentation.component,
58-
['*'],
59-
this.patch.bind(this),
60-
this.unpatch.bind(this)
61-
);
56+
const module: InstrumentationModuleDefinition<typeof kafkaJs> = new InstrumentationNodeModuleDefinition<
57+
typeof kafkaJs
58+
>(KafkaJsInstrumentation.component, ['*'], this.patch.bind(this), this.unpatch.bind(this));
59+
module.includePrerelease = true;
6260
return module;
6361
}
6462

0 commit comments

Comments
 (0)