gcs-connector-for-apache-kafka
gcs-connector-for-apache-kafka copied to clipboard
Autodiscover Credentials with Workload Identity Broken Since v0.10.0
I'm running Kafka Connect in GKE and using Workload Identity to provision a GCP service account into the container. This is working perfectly on v0.9.1.
Attempting to upgrade to v0.10.0 with the exact same config I get the following error:
Caused by: com.google.api.client.http.HttpResponseException: 401 Unauthorized
I've also tried v0.11.0 and v0.13.0. I then downgraded back to v0.9.1 and everything is fine.
Could perhaps be related to this change? https://github.com/Aiven-Open/gcs-connector-for-apache-kafka/commit/ff3a51d9d7af607c67b108e2469ac1f7aa1fd175#diff-6c787db8b668bb3e6986238c0a507af75dbbefae041b407ba029b4e3f1f33e43R329-R335