From bb8f80f25669b67f4b767c1ae5cc9802a74ea784 Mon Sep 17 00:00:00 2001 From: "Zaiming (Stone) Shi" Date: Mon, 6 Nov 2023 21:59:36 +0100 Subject: [PATCH] test: add test case to pin bridge schema json version 0.1.0 --- apps/emqx_bridge_kafka/test/emqx_bridge_kafka_tests.erl | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/apps/emqx_bridge_kafka/test/emqx_bridge_kafka_tests.erl b/apps/emqx_bridge_kafka/test/emqx_bridge_kafka_tests.erl index c67750afd..1d9682b9b 100644 --- a/apps/emqx_bridge_kafka/test/emqx_bridge_kafka_tests.erl +++ b/apps/emqx_bridge_kafka/test/emqx_bridge_kafka_tests.erl @@ -361,3 +361,10 @@ bridges.kafka_consumer.my_consumer { } } """. + +%% assert compatibility +bridge_schema_json_test() -> + JSON = iolist_to_binary(emqx_conf:bridge_schema_json()), + Map = emqx_utils_json:decode(JSON), + Path = [<<"components">>, <<"schemas">>, <<"bridge_kafka.post_producer">>, <<"properties">>], + ?assertMatch(#{<<"kafka">> := _}, emqx_utils_maps:deep_get(Path, Map)).