diff --git a/apps/emqx_schema_registry/src/emqx_schema_registry.erl b/apps/emqx_schema_registry/src/emqx_schema_registry.erl index f8d760ddc..6d58f4127 100644 --- a/apps/emqx_schema_registry/src/emqx_schema_registry.erl +++ b/apps/emqx_schema_registry/src/emqx_schema_registry.erl @@ -339,6 +339,7 @@ ensure_serde_absent(Name) -> {ok, Serde} -> ok = emqx_schema_registry_serde:destroy(Serde), _ = ets:delete(?SERDE_TAB, Name), + ?tp("schema_registry_serde_deleted", #{name => Name}), ok; {error, not_found} -> ok diff --git a/apps/emqx_schema_registry/test/emqx_schema_registry_serde_SUITE.erl b/apps/emqx_schema_registry/test/emqx_schema_registry_serde_SUITE.erl index bdc083736..33727e8f1 100644 --- a/apps/emqx_schema_registry/test/emqx_schema_registry_serde_SUITE.erl +++ b/apps/emqx_schema_registry/test/emqx_schema_registry_serde_SUITE.erl @@ -57,7 +57,15 @@ end_per_testcase(_TestCase, _Config) -> clear_schemas() -> maps:foreach( fun(Name, _Schema) -> - ok = emqx_schema_registry:delete_schema(Name) + NameBin = emqx_utils_conv:bin(Name), + {ok, {ok, _}} = + ?wait_async_action( + emqx_schema_registry:delete_schema(Name), + #{ + ?snk_kind := "schema_registry_serde_deleted", + name := NameBin + } + ) end, emqx_schema_registry:list_schemas() ).