|
|
@@ -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)).
|