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

Support for avro schema for kafka sink #679

Open
hazelnut-99 opened this issue Jul 8, 2024 · 1 comment
Open

Support for avro schema for kafka sink #679

hazelnut-99 opened this issue Jul 8, 2024 · 1 comment

Comments

@hazelnut-99
Copy link

As mentioned in the docs, "Currently, Kafka sinks only support writing JSON data, with the structure determined by the schema of the data being written."

It will be a really nice and useful feature to support avro schema for kafka sink. For example, currently in our use case, all data written to and read from kafka are avro-based.

@hazelnut-99
Copy link
Author

Oh, it seems that it's already supported! I managed to make it work by specifying this parameter 'avro.confluent_schema_registry' = 'true' in the sink definition.

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

No branches or pull requests

1 participant