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

avro schema for key and value for confluent kafka schema registry #1071

Open
leonardotorresaltez opened this issue Oct 4, 2024 · 3 comments
Labels
❔ Question A question about the spec or processes

Comments

@leonardotorresaltez
Copy link

leonardotorresaltez commented Oct 4, 2024

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

@leonardotorresaltez leonardotorresaltez added the ❔ Question A question about the spec or processes label Oct 4, 2024
Copy link

github-actions bot commented Oct 4, 2024

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.
Keep in mind there are also other channels you can use to interact with AsyncAPI community. For more details check out this issue.

Copy link

github-actions bot commented Feb 4, 2025

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 ❤️

@github-actions github-actions bot added the stale label Feb 4, 2025
@Karan-Palan
Copy link

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 schemaFormat and defining separate schemas for the key and value.

Example:
You can define the message like this:

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,

  1. The key and value fields in the messages section allow you to define separate schemas.
  2. schemaFormat: application/vnd.apache.avro+json ensures that Avro is used.
  3. The KeySchema and ValueSchema are defined separately in components.schemas.

Would this approach work for your use case?

@github-actions github-actions bot removed the stale label Feb 11, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
❔ Question A question about the spec or processes
Projects
None yet
Development

No branches or pull requests

2 participants