Need help!!ERROR:[pipeline_kafka] y_kk_stream <- xxxxxxxx(pid xxxx) :failed to acquire metadata:local:timed out

[val-sy]

when i config as readme.md，start consume_begin，pipelinedb logfile notice an error: failed to acquire metadata : local : timed out ,why? consume_begin consume topic use kafkacat?where can config this? another question:when consume topic ,it need security certificate? where can config it ?

thanks!