You can change sink type from broker to other type like fakesink to see if the pipeline stuck, if not stuck, the issue should be not related to broker, something like that, until find which components caused your pipeline stuck.
if possile, you could share the sample for a local try.