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

Using Codec[A] with KafkaStreams #1144

Open
caenrique opened this issue Jan 26, 2023 · 0 comments
Open

Using Codec[A] with KafkaStreams #1144

caenrique opened this issue Jan 26, 2023 · 0 comments

Comments

@caenrique
Copy link

I'm thinking about how to get a org.apache.kafka.common.serialization.Serde from a Codec.

We are moving our schema from json avro to case classes with vulcan, and we use it with fs2 without problem, but we also have kafka streams applications.

Without including this (fs2-kafka) dependency, I think the only option would be to re-imlement a lot of the functionality to make the schema work well with the schema registry (eg: the vulcan module here but targeting the java Serde)

Basically I would appreciate help with interop between vulcan and native kafka apis :)
Maybe I'm missing something and there is a simple way. If not it would be awesome to have it

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

No branches or pull requests

1 participant