Skip to content

feat(kafka): new kafka utility #4058

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.

Sign up for GitHub

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

Jump to bottom
Merged
merged 87 commits into from
Jun 18, 2025
Merged

feat(kafka): new kafka utility #4058

merged 87 commits into from
Jun 18, 2025

Conversation

am29d
Copy link
Contributor

@am29d am29d commented Jun 18, 2025 •
edited by dreamorosi
Loading

Summary

Changes

Please provide a summary of what's being changed

  • Adds a new Kafka utility to the library which is useful for processing events from Kafka.

Please add the issue number below, if no issue is present the PR might get blocked and not be reviewed

Issue number: closes #4057

By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.

Disclaimer: We value your time and bandwidth. As such, any pull requests created on non-triaged issues might not be successful.
dreamorosi and others added 30 commits May 28, 2025 23:33
@dreamorosi
chore: add pkg structure
418d72a
@am29d
add json case impl
e595979
@am29d
add avro impl and test
02ddd8f
@am29d
fix tests
eb3d200
@am29d
ignore schema coverage for now
d0aceb1
@am29d
add protobuf support
c4a0cd0
@am29d
fix tests
103002e
@am29d
add headers and types
45badaf
@am29d
refactored deserialiser
8dddc99
@am29d
remove zod schema for now
fd5f11d
@am29d
add unsupported error
df8a052
@am29d
restrict type for avro and protobuf
c80e3a8
@am29d
remove outputobjc param for now
41fd277
@am29d
return base64 encoded string if no config provided
d9aedb8
@am29d
allow headers to be null
90912a9
@am29d
add readme
a53ed79
@am29d
fix return type to event
f64b83e
@am29d
update readme
086e742
@am29d
added zod schema validation
9aa6041
@am29d
adjust examples
afbaa08
@am29d
Add JSDoc comments and rename deserialiser to deserializer
a970496
@am29d
Rename deserialiser.test.ts to deserializer.test.ts
a77eb1b
@am29d
replace protobuf lib, wrap parser error, refacto deserialiser
ba9bd75
@am29d
fixed examples
700d051
@am29d
fixed example
4fe0a3b
@am29d
addressed feedback to have more specific types
a881df3
@am29d
add more test cases
21f495d
@am29d
Add Arrange-Act-Assert comments to unit tests for clarity
ee392a0
@am29d
change exmaples for perf tests
96b930b
@am29d
rewrite map to for loop
847dbe5
@boring-cyborg boring-cyborg bot added the dependencies Changes that touch dependencies, e.g. Dependabot, etc. label Jun 18, 2025
@pull-request-size pull-request-size bot added the size/XXL PRs with 1K+ LOC, largely documentation related label Jun 18, 2025
leandrodamascena
leandrodamascena requested changes Jun 18, 2025
View reviewed changes
Copy link
Contributor

@leandrodamascena leandrodamascena left a comment

Choose a reason for hiding this comment

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

Hey @dreamorosi only 2 small comments.
@sonarqubecloud SonarQubeCloud
Copy link

Quality Gate Passed Quality Gate passed

Issues
0 New issues
0 Accepted issues

Measures
0 Security Hotspots
0.0% Coverage on New Code
20.1% Duplication on New Code

See analysis details on SonarQube Cloud
leandrodamascena
leandrodamascena approved these changes Jun 18, 2025
View reviewed changes
Copy link
Contributor

@leandrodamascena leandrodamascena left a comment

Choose a reason for hiding this comment

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

Thanks a lot for this super work here @am29d and @dreamorosi! APPROVED!!!
@dreamorosi dreamorosi merged commit 006f27b into main Jun 18, 2025
47 checks passed
@dreamorosi dreamorosi deleted the feat/kafka branch June 18, 2025 18:11
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
automation This item relates to automation dependencies Changes that touch dependencies, e.g. Dependabot, etc. size/XXL PRs with 1K+ LOC, largely documentation related
3 participants
@am29d @leandrodamascena @dreamorosi