Hello everybody,

I have a secure kafka instance on-premises that I would like to read from
using a Dataflow job. The idea is to have the connection to the kafka only
from dataflow machines.

But when I run the job with Dataflow runner it does attempt to connect to
the kafka instance. Surely it fails and the job is not deployed.

I suspect that there is some kind of a verification step that the job
compiler is doing locally before deployment. Is there more
documentation around the topic? Is there a way to control what will happen
during the verification process?

Regards,
Dmytro

Reply via email to