Skip to content
New issue

Have a question about this project? # for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “#”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? # to your account

Add schematized produce by looking up latest schema version #584

Open
rohitsanj opened this issue Nov 13, 2024 · 0 comments · May be fixed by #1093
Open

Add schematized produce by looking up latest schema version #584

rohitsanj opened this issue Nov 13, 2024 · 0 comments · May be fixed by #1093
Assignees

Comments

@rohitsanj
Copy link
Contributor

rohitsanj commented Nov 13, 2024

Fetch latest schema for the key/value and pass in the schema_version in the Produce Records payload.

Example
(This payload body is what Sidecar expects and is not an exact copy of the message file contents)

curl http://localhost:26636/kafka/v3/clusters/my-cluster/topics/my-topic/records \
-H "Authorization: Bearer $access_token" \
-H "X-connection-id": "my-connection-id" \
-d '{
  "headers": {
    "foo": "bar"
  }
  "key": {
    "schema_version": 2,
    "data": 123
  },
  "value": {
    "schema_version": 3,
    "data":  {
      "ordertime": 1505510136717,
      "orderid": 1238,
      "itemid": "Item_92",
      "orderunits": 6.302653935989815,
      "address": {
        "city": "City_",
        "state": "State_47",
        "zipcode": 91197
      }
    }
  }
}'
@shouples shouples self-assigned this Jan 23, 2025
@shouples shouples linked a pull request Feb 28, 2025 that will close this issue
6 tasks
# for free to join this conversation on GitHub. Already have an account? # to comment
Labels
None yet
Projects
None yet
Development

Successfully merging a pull request may close this issue.

2 participants