Hello Everyone,
I am reaching out here for guidance as am unable to create a successful connection between the Cloud Data Fusion instance and the self-managed Kafka cluster running on the GCE instance privately. I would appreciate it if I can get any sort of help here. Thanks
This can be happening due to a Kafka limitation, where it only accepts requests to the Kafka brokers' registered listener endpoints (in this case the default hostname URLs and not the actual IPs).
To resolve this you need to re-configure your Kafka settings advertised.listeners property to the internal IPs. See :