Skip to content

Commit ef0dfb0

Browse files
committed
pandaproxy/sr: Add explicit sync for schema/ids
1 parent 885ae34 commit ef0dfb0

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

src/v/pandaproxy/schema_registry/handlers.cc

+5
Original file line numberDiff line numberDiff line change
@@ -304,6 +304,11 @@ get_schemas_ids_id(server::request_t rq, server::reply_t rp) {
304304
auto id = parse::request_param<schema_id>(*rq.req, "id");
305305
rq.req.reset();
306306

307+
// With deferred schema validation, there might be a schema that
308+
// had invalid references. These might have already been posted, soft
309+
// we need to sync
310+
co_await rq.service().writer().read_sync();
311+
307312
auto def = co_await get_or_load(rq, [&rq, id]() {
308313
return rq.service().schema_store().get_schema_definition(id);
309314
});

0 commit comments

Comments
 (0)