GoogleCloudPlatform / DataflowTemplates

Cloud Dataflow Google-provided templates for solving in-Cloud data tasks
https://cloud.google.com/dataflow/docs/guides/templates/provided-templates
Apache License 2.0
1.12k stars 936 forks source link

Add OauthBearer auth support for Managed Kafka templates. #1649

Closed AnandInguva closed 1 month ago

codecov[bot] commented 1 month ago

Codecov Report

Attention: Patch coverage is 0% with 68 lines in your changes missing coverage. Please review.

Project coverage is 41.17%. Comparing base (66f4322) to head (cc6ce1a). Report is 3 commits behind head on main.

Additional details and impacted files ```diff @@ Coverage Diff @@ ## main #1649 +/- ## ============================================ - Coverage 41.23% 41.17% -0.07% + Complexity 2928 2927 -1 ============================================ Files 763 764 +1 Lines 44393 44456 +63 Branches 4754 4762 +8 ============================================ - Hits 18305 18304 -1 - Misses 24545 24608 +63 - Partials 1543 1544 +1 ``` | [Components](https://app.codecov.io/gh/GoogleCloudPlatform/DataflowTemplates/pull/1649/components?src=pr&el=components&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=GoogleCloudPlatform) | Coverage Δ | | |---|---|---| | [spanner-templates](https://app.codecov.io/gh/GoogleCloudPlatform/DataflowTemplates/pull/1649/components?src=pr&el=component&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=GoogleCloudPlatform) | `61.37% <ø> (-0.01%)` | :arrow_down: | | [spanner-import-export](https://app.codecov.io/gh/GoogleCloudPlatform/DataflowTemplates/pull/1649/components?src=pr&el=component&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=GoogleCloudPlatform) | `64.42% <ø> (-0.03%)` | :arrow_down: | | [spanner-live-forward-migration](https://app.codecov.io/gh/GoogleCloudPlatform/DataflowTemplates/pull/1649/components?src=pr&el=component&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=GoogleCloudPlatform) | `73.88% <ø> (ø)` | | | [spanner-live-reverse-replication](https://app.codecov.io/gh/GoogleCloudPlatform/DataflowTemplates/pull/1649/components?src=pr&el=component&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=GoogleCloudPlatform) | `49.66% <ø> (ø)` | | | [spanner-bulk-migration](https://app.codecov.io/gh/GoogleCloudPlatform/DataflowTemplates/pull/1649/components?src=pr&el=component&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=GoogleCloudPlatform) | `82.07% <ø> (ø)` | | | [Files](https://app.codecov.io/gh/GoogleCloudPlatform/DataflowTemplates/pull/1649?dropdown=coverage&src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=GoogleCloudPlatform) | Coverage Δ | | |---|---|---| | [...ud/teleport/v2/kafka/options/KafkaReadOptions.java](https://app.codecov.io/gh/GoogleCloudPlatform/DataflowTemplates/pull/1649?src=pr&el=tree&filepath=v2%2Fkafka-common%2Fsrc%2Fmain%2Fjava%2Fcom%2Fgoogle%2Fcloud%2Fteleport%2Fv2%2Fkafka%2Foptions%2FKafkaReadOptions.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=GoogleCloudPlatform#diff-djIva2Fma2EtY29tbW9uL3NyYy9tYWluL2phdmEvY29tL2dvb2dsZS9jbG91ZC90ZWxlcG9ydC92Mi9rYWZrYS9vcHRpb25zL0thZmthUmVhZE9wdGlvbnMuamF2YQ==) | `0.00% <ø> (ø)` | | | [...ort/v2/kafka/values/KafkaAuthenticationMethod.java](https://app.codecov.io/gh/GoogleCloudPlatform/DataflowTemplates/pull/1649?src=pr&el=tree&filepath=v2%2Fkafka-common%2Fsrc%2Fmain%2Fjava%2Fcom%2Fgoogle%2Fcloud%2Fteleport%2Fv2%2Fkafka%2Fvalues%2FKafkaAuthenticationMethod.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=GoogleCloudPlatform#diff-djIva2Fma2EtY29tbW9uL3NyYy9tYWluL2phdmEvY29tL2dvb2dsZS9jbG91ZC90ZWxlcG9ydC92Mi9rYWZrYS92YWx1ZXMvS2Fma2FBdXRoZW50aWNhdGlvbk1ldGhvZC5qYXZh) | `0.00% <ø> (ø)` | | | [...s/KafkaRecordToGenericRecordFailsafeElementFn.java](https://app.codecov.io/gh/GoogleCloudPlatform/DataflowTemplates/pull/1649?src=pr&el=tree&filepath=v2%2Fkafka-common%2Fsrc%2Fmain%2Fjava%2Fcom%2Fgoogle%2Fcloud%2Fteleport%2Fv2%2Fkafka%2Ftransforms%2FKafkaRecordToGenericRecordFailsafeElementFn.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=GoogleCloudPlatform#diff-djIva2Fma2EtY29tbW9uL3NyYy9tYWluL2phdmEvY29tL2dvb2dsZS9jbG91ZC90ZWxlcG9ydC92Mi9rYWZrYS90cmFuc2Zvcm1zL0thZmthUmVjb3JkVG9HZW5lcmljUmVjb3JkRmFpbHNhZmVFbGVtZW50Rm4uamF2YQ==) | `0.00% <0.00%> (ø)` | | | [...gle/cloud/teleport/v2/kafka/utils/KafkaConfig.java](https://app.codecov.io/gh/GoogleCloudPlatform/DataflowTemplates/pull/1649?src=pr&el=tree&filepath=v2%2Fkafka-common%2Fsrc%2Fmain%2Fjava%2Fcom%2Fgoogle%2Fcloud%2Fteleport%2Fv2%2Fkafka%2Futils%2FKafkaConfig.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=GoogleCloudPlatform#diff-djIva2Fma2EtY29tbW9uL3NyYy9tYWluL2phdmEvY29tL2dvb2dsZS9jbG91ZC90ZWxlcG9ydC92Mi9rYWZrYS91dGlscy9LYWZrYUNvbmZpZy5qYXZh) | `0.00% <0.00%> (ø)` | | | [...eleport/v2/kafka/auth/GcpLoginCallbackHandler.java](https://app.codecov.io/gh/GoogleCloudPlatform/DataflowTemplates/pull/1649?src=pr&el=tree&filepath=v2%2Fkafka-common%2Fsrc%2Fmain%2Fjava%2Fcom%2Fgoogle%2Fcloud%2Fteleport%2Fv2%2Fkafka%2Fauth%2FGcpLoginCallbackHandler.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=GoogleCloudPlatform#diff-djIva2Fma2EtY29tbW9uL3NyYy9tYWluL2phdmEvY29tL2dvb2dsZS9jbG91ZC90ZWxlcG9ydC92Mi9rYWZrYS9hdXRoL0djcExvZ2luQ2FsbGJhY2tIYW5kbGVyLmphdmE=) | `0.00% <0.00%> (ø)` | | ... and [1 file with indirect coverage changes](https://app.codecov.io/gh/GoogleCloudPlatform/DataflowTemplates/pull/1649/indirect-changes?src=pr&el=tree-more&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=GoogleCloudPlatform)