mz_
testdrive
0.154.0-dev.0
In mz_
testdrive::
action::
kafka::
wait_
topic
mz_testdrive
::
action
::
kafka
::
wait_topic
Function
check_topic_exists
Copy item path
Source
pub(crate) async fn check_topic_exists( topic: &
str
, state: &
State
, ) ->
Result
<
()
,
Error
>