[service-utils] Add kafka producer to emit raw messages #6170
Conversation
|
The latest updates on your projects. Learn more about Vercel for Git ↗︎
|
🦋 Changeset detectedLatest commit: f32c128 The changes in this PR will be included in the next version bump. This PR includes changesets to release 1 package
Not sure what this means? Click here to learn what changesets are. Click here if you're a maintainer who wants to add another changeset to this PR |
![graphite-app[bot]](https://avatars.githubusercontent.com/in/158384?s=60&v=4){kind=small}
| /** | ||
| * Send messages to a Kafka topic. | ||
| * This method may throw. To call this non-blocking: | ||
| * | ||
| * ```ts | ||
| * kafka = new KafkaProducer(...) | ||
| * void kafka.send(topic, messages).catch(console.error) | ||
| * | ||
| * @param topic | ||
| * @param messages | ||
| * @param configOverrides | ||
| */ |
There was a problem hiding this comment.
The code example in the JSDoc is missing a closing code fence. Adding \``after.catch(console.error)` will ensure proper documentation generation.
Spotted by Graphite Reviewer
Is this helpful? React 👍 or 👎 to let us know.
How to use the Graphite Merge QueueAdd either label to this PR to merge it via the merge queue:
You must have a Graphite account in order to use the merge queue. Sign up using this link. An organization admin has enabled the Graphite Merge Queue in this repository. Please do not merge from GitHub as this will restart CI on PRs being processed by the merge queue. |
Codecov ReportAll modified and coverable lines are covered by tests ✅
Additional details and impacted files@@ Coverage Diff @@
## main #6170 +/- ##
=======================================
Coverage 56.92% 56.92%
=======================================
Files 1155 1155
Lines 63923 63923
Branches 5193 5193
=======================================
Hits 36386 36386
Misses 26808 26808
Partials 729 729
*This pull request uses carry forward flags. Click here to find out more. |
size-limit report 📦
|
Notes for the reviewer
Anything important to call out? Be sure to also clarify these in your comments.
How to test
Unit tests, playground, etc.
-->
PR-Codex overview
This PR introduces a new
KafkaProducerclass to handle Kafka message production, enhancing the existingUsageV2Producerby integrating the new producer for sending events more efficiently and managing compression.Detailed summary
KafkaProducerclass inpackages/service-utils/src/node/kafka.ts.UsageV2Producerto utilizeKafkaProducer.UsageV2Producer.