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

feat: Add the ability to decode the Kafka Avro key and not just the value #20248

Open
steeleworker opened this issue Jan 21, 2025 · 1 comment

Comments

@steeleworker
Copy link

Is your feature request related to a problem? Please describe.

When decoding Avro Kafka messages using the schema registry, currently only the value is decoded. Although you can INCLUDE key it means the column is a bytea type. However the key in our data is avro encoded. This prevents us from building an index on any property that is part of the key and forces us pull everything back on the client side and decode.

Describe the solution you'd like

It would be great if we had the option to decode the kafka key which is in Avro format.

Describe alternatives you've considered

No response

Additional context

No response

@github-actions github-actions bot added this to the release-2.3 milestone Jan 21, 2025
@steeleworker
Copy link
Author

steeleworker commented Jan 21, 2025

@xiangjinwu Looks like you have contributed to some of the related code. What do you think?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

1 participant