|
@@ -132,7 +132,7 @@ t_query_mode(CtConfig) ->
|
|
|
begin
|
|
begin
|
|
|
publish_with_config_template_parameters(CtConfig1, #{"query_mode" => "sync"})
|
|
publish_with_config_template_parameters(CtConfig1, #{"query_mode" => "sync"})
|
|
|
end,
|
|
end,
|
|
|
- fun(RunStageResult, Trace) ->
|
|
|
|
|
|
|
+ fun(Trace) ->
|
|
|
%% We should have a sync Snabbkaffe trace
|
|
%% We should have a sync Snabbkaffe trace
|
|
|
?assertMatch([_], ?of_kind(emqx_bridge_kafka_impl_producer_sync_query, Trace))
|
|
?assertMatch([_], ?of_kind(emqx_bridge_kafka_impl_producer_sync_query, Trace))
|
|
|
end
|
|
end
|
|
@@ -141,7 +141,7 @@ t_query_mode(CtConfig) ->
|
|
|
begin
|
|
begin
|
|
|
publish_with_config_template_parameters(CtConfig1, #{"query_mode" => "async"})
|
|
publish_with_config_template_parameters(CtConfig1, #{"query_mode" => "async"})
|
|
|
end,
|
|
end,
|
|
|
- fun(RunStageResult, Trace) ->
|
|
|
|
|
|
|
+ fun(Trace) ->
|
|
|
%% We should have a sync Snabbkaffe trace
|
|
%% We should have a sync Snabbkaffe trace
|
|
|
?assertMatch([_], ?of_kind(emqx_bridge_kafka_impl_producer_async_query, Trace))
|
|
?assertMatch([_], ?of_kind(emqx_bridge_kafka_impl_producer_async_query, Trace))
|
|
|
end
|
|
end
|