-
Notifications
You must be signed in to change notification settings - Fork 76
PLAT-707 Add kafka integration #1188
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
Conversation
Codecov Report
@@ Coverage Diff @@
## master #1188 +/- ##
==========================================
+ Coverage 86.56% 86.65% +0.09%
==========================================
Files 85 87 +2
Lines 5806 5876 +70
==========================================
+ Hits 5026 5092 +66
- Misses 780 784 +4
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Left a couple of comments. Looks good overall
We may rename KafkaProducerSet to KafkaProducerManager.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looking good on a first pass review. I've added some comments.
…,201 etc would be ignored
… needed, rather than all on server startup
…wo producers with the same clientId in different channels don't conflict.
…fka routes will use
…e folder as it is not a middleware and placed it in the root instead
…07-kafka-integration
…tion if a kafka route is the primary route
…-core-js into PLAT-707-kafka-integration
…-core-js into PLAT-707-kafka-integration
…tting the response metrics on the route
…catch since parseInt does not throw but instead returns NaN if it fails to parse. Add tests to cover the new logic
…-core-js into PLAT-707-kafka-integration
This reverts commit 2b63df6.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Great work, this looks awesome.
No description provided.