-
-
Notifications
You must be signed in to change notification settings - Fork 289
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
avro schema for key and value for confluent kafka schema registry #1071
Comments
Welcome to AsyncAPI. Thanks a lot for reporting your first issue. Please check out our contributors guide and the instructions about a basic recommended setup useful for opening a pull request. |
This issue has been automatically marked as stale because it has not had recent activity 😴 It will be closed in 120 days if no further activity occurs. To unstale this issue, add a comment with a detailed explanation. There can be many reasons why some specific issue has no activity. The most probable cause is lack of time, not lack of interest. AsyncAPI Initiative is a Linux Foundation project not owned by a single for-profit company. It is a community-driven initiative ruled under open governance model. Let us figure out together how to push this issue forward. Connect with us through one of many communication channels we established here. Thank you for your patience ❤️ |
Hey @leonardotorresaltez , from what I understand using Async Api in my project, you can specify different Avro schemas for the key and value in a Kafka message by using Example: asyncapi: 3.0.0
info:
title: Kafka Avro Example
version: 1.0.0
servers:
kafka-broker:
url: kafka.example.com:9092
protocol: kafka
description: Kafka broker
channels:
my-topic:
address: my-topic
messages:
key:
contentType: application/vnd.apache.avro+json
schemaFormat: application/vnd.apache.avro+json
schema:
$ref: "#/components/schemas/KeySchema"
value:
contentType: application/vnd.apache.avro+json
schemaFormat: application/vnd.apache.avro+json
schema:
$ref: "#/components/schemas/ValueSchema"
components:
schemas:
KeySchema:
type: string # Example: Could also be an Avro schema reference
ValueSchema:
type: object
properties:
id:
type: string
name:
type: string Here,
Would this approach work for your use case? |
Hello i am looking some example in the spec version 3.0 about using different avro schemas for key and value.
both schemas live in confluent schema registry .
How to specify a message key and value in asyncapi contract ?
regards,
Leonardo
The text was updated successfully, but these errors were encountered: