Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add KafkaJS support #1146

Merged

Conversation

puzzledbytheweb
Copy link
Contributor

@puzzledbytheweb puzzledbytheweb commented Nov 2, 2020

What does this PR do?

This PR adds KafkaJS support in this package, using their own instrumentation events.

Motivation

Using DD-trace in my work we were a bit disappointed that there was no out-of-the-box support for KafkaJS.

Plugin Checklist

Additional Notes

I think I'll need some help with not only the the usual "make this work" stuff but also with the unit tests and what do we care testing.

Cheers!

@puzzledbytheweb puzzledbytheweb requested a review from a team as a code owner November 2, 2020 14:34
@puzzledbytheweb puzzledbytheweb changed the title Puzzledbytheweb/kafkajs plugin Add KafkaJS support Nov 2, 2020
packages/datadog-plugin-kafkajs/src/index.js Outdated Show resolved Hide resolved
packages/datadog-plugin-kafkajs/src/index.js Outdated Show resolved Hide resolved
packages/datadog-plugin-kafkajs/src/index.js Outdated Show resolved Hide resolved
packages/datadog-plugin-kafkajs/src/index.js Outdated Show resolved Hide resolved
.circleci/config.yml Outdated Show resolved Hide resolved
@rochdev rochdev requested a review from bengl December 21, 2020 21:11
currentSpan.addTags({
'resource.name': topic,
'kafka.topic': topic,
'kafka.batch.size': messages.length
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@rochdev should this be changed before merge?

@puzzledbytheweb
Copy link
Contributor Author

#1146 (comment)

I did it this way erroneously, it should be kafka.batch_size

@rochdev rochdev merged commit 1bcfea3 into DataDog:master Jan 6, 2021
Czechh added a commit that referenced this pull request Jan 11, 2021
* master:
  fix ts for aws split-by-service change (#1201)
  [ci-app] Better Test Name in Jest Instrumentation (#1190)
  v0.30.0 (#1198)
  add type definitions for aws-sdk service configuration (#1197)
  add option to enable/disable tracing of individual aws services (#1193)
  replace blacklist and whitelist with blocklist and allowlist (#1196)
  add container tagging support for ecs docker id (#1176)
  add option to split ioredis service name by instance (#1194)
  Call options fn on each invocation in tracer.wrap (#1191)
  export the tracer from implicit init file (#1192)
  fix double-routing in restify (#1161)
  [CIAPP-474] Mocha support (#1162)
  Add KafkaJS support (#1146)
  Revert "wrap end on prototype instead of instances (#1127)" (#1189)
  fix missing span types in some web and worker plugins (#1178)
  [ci-app] Fix Jest Flaky Test Setup and Use More Supported Branch Extraction (#1188)
@puzzledbytheweb puzzledbytheweb deleted the puzzledbytheweb/kafkajs-plugin branch October 15, 2021 10:42
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

4 participants