KafkaJs instrumentation does not work.
MattGson opened this issue · 2 comments
MattGson commented
The KafkaJS instrumentation is not setting any headers on the messages.
Versions:
"@opentelemetry/api": "^1.0.3",
"@opentelemetry/core": "^1.0.0",
"@opentelemetry/exporter-jaeger": "^1.0.0",
"@opentelemetry/exporter-prometheus": "^0.27.0",
"@opentelemetry/instrumentation": "^0.27.0",
"@opentelemetry/instrumentation-express": "^0.27.0",
"@opentelemetry/instrumentation-http": "^0.27.0",
"@opentelemetry/resources": "^1.0.0",
"@opentelemetry/sdk-node": "^0.27.0",
"@opentelemetry/sdk-trace-base": "^1.0.0",
"@opentelemetry/sdk-metrics-base": "^0.27.0",
"@opentelemetry/sdk-trace-node": "^1.0.0",
"@opentelemetry/semantic-conventions": "^1.0.1",
"opentelemetry-instrumentation-elasticsearch": "^0.27.1",
"opentelemetry-instrumentation-kafkajs": "^0.27.1",
"@opentelemetry/propagator-b3": "^1.2.0",
"@opentelemetry/propagator-jaeger": "^1.2.0",
blumamir commented
Are spans still created?
Can you please share a code snippet that reproduces the issue?
MattGson commented
Just played around with this and realised one important version I left out:
"kafkajs": "^1.17.0-beta.5",
Changing to
"kafkajs": "^1.16.0",
Fixes it.
Looks like there is a breaking change for this lib in 1.17 so something to be aware of.
I'll find out if we can drop to 1.16 in the mean time.