mz_testdrive
0.89.0-dev
In mz_testdrive::action::kafka::verify_data
?
Function
mz_testdrive
::
action
::
kafka
::
verify_data
::
get_topic
source
·
[
−
]
async fn get_topic( sink: &
str
, topic_field: &
str
, state: &
State
) ->
Result
<
String
,
Error
>