aspecto-io
diff --git a/‎packages/plugin-kafkajs/src/kafkajs.ts‎
Lines changed: 1 addition & 1 deletion b/‎packages/plugin-kafkajs/src/kafkajs.ts‎
Lines changed: 1 addition & 1 deletion
@@ -169,7 +169,7 @@ export class KafkaJsPlugin extends BasePlugin<typeof kafkaJs> {
         const span = this._tracer.startSpan(
             topic,
             {
-                kind: SpanKind.PRODUCER,
+                kind: SpanKind.CONSUMER,
                 attributes: {
                     [AttributeNames.MESSAGING_SYSTEM]: 'kafka',
                     [AttributeNames.MESSAGING_DESTINATION]: topic,
Original file line number	Diff line number	Diff line change
`@@ -169,7 +169,7 @@ export class KafkaJsPlugin extends BasePlugin<typeof kafkaJs> {`
`169`	`169`	`const span = this._tracer.startSpan(`
`170`	`170`	`topic,`
`171`	`171`	`{`
`172`		`- kind: SpanKind.PRODUCER,`
	`172`	`+ kind: SpanKind.CONSUMER,`
`173`	`173`	`attributes: {`
`174`	`174`	`[AttributeNames.MESSAGING_SYSTEM]: 'kafka',`
`175`	`175`	`[AttributeNames.MESSAGING_DESTINATION]: topic,`