-
Notifications
You must be signed in to change notification settings - Fork 2.4k
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
[exporter/kafka] Implement partitioning by resource attributes for logs #33230
[exporter/kafka] Implement partitioning by resource attributes for logs #33230
Conversation
This PR was marked stale due to lack of activity. It will be closed in 14 days. |
Hi @MovieStoreGuy. Could you please have a look at PR? Thank you. |
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.
This seems okay, but please clean up your commits to help provide context around the changes being made.
3383023
to
b023168
Compare
Hi @MovieStoreGuy. Please have a look. |
This PR was marked stale due to lack of activity. It will be closed in 14 days. |
Hello @MovieStoreGuy, @atoulme. Could you please help to merge the PR? Thank you. |
I can't merge but @MovieStoreGuy can. |
Description: Add resource attributes based partitioning for logs
Link to tracking Issue: #33229
Testing: Added test and tested locally
Documentation: Documented new flag.
Additionally, as discussed with @dmitryax in #31315, removed trait with Key method and refactored the code to pass flags directly to marshaller constructors. Please let me know if this way is acceptable.
I also removed an ability to add custom marshallers - option to add custom marshallers was unexposed in 0.89.0, so now the code was just sitting there unused.