v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToBigQuery.java
yaml/src/main/java/com/google/cloud/teleport/templates/yaml/KafkaToBigQueryYaml.java

v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToBigQueryFlex.java
yaml/src/main/java/com/google/cloud/teleport/templates/yaml/KafkaToBigQueryYaml.java

v2/pubsub-cdc-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/PubSubCdcToBigQuery.java
yaml/src/main/java/com/google/cloud/teleport/templates/yaml/KafkaToBigQueryYaml.java