Skip to content

Allow defining multiple source kafka topics #2060

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
Fadelis wants to merge 1 commit into from

support defining multiple source kafka topics and possibility to pers…

900b2e5
Select commit
Loading
Failed to load commit list.
Closed

Allow defining multiple source kafka topics #2060

support defining multiple source kafka topics and possibility to pers…
900b2e5
Select commit
Loading
Failed to load commit list.
Codecov / codecov/patch succeeded Jul 12, 2025 in 1s

36.36% of diff hit (target 80.00%)

View this Pull Request on Codecov

36.36% of diff hit (target 80.00%)

Annotations

Check warning on line 245 in v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToBigQueryFlex.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

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

Added line #L245 was not covered by tests

Check warning on line 317 in v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToBigQueryFlex.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

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

Added line #L317 was not covered by tests

Check warning on line 330 in v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToBigQueryFlex.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

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

Added line #L330 was not covered by tests

Check warning on line 375 in v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToBigQueryFlex.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

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

Added line #L375 was not covered by tests

Check warning on line 388 in v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToBigQueryFlex.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

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

Added line #L388 was not covered by tests

Check warning on line 96 in v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryWriteUtils.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryWriteUtils.java#L96 

Added line #L96 was not covered by tests

Check warning on line 120 in v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryWriteUtils.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryWriteUtils.java#L120 

Added line #L120 was not covered by tests

Check warning on line 181 in v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryWriteUtils.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryWriteUtils.java#L181 

Added line #L181 was not covered by tests

Check warning on line 183 in v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryWriteUtils.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryWriteUtils.java#L183 

Added line #L183 was not covered by tests

Check warning on line 198 in v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryWriteUtils.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryWriteUtils.java#L198 

Added line #L198 was not covered by tests

Check warning on line 249 in v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryWriteUtils.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryWriteUtils.java#L248-L249 

Added lines #L248 - L249 were not covered by tests

Check warning on line 139 in v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToGcsFlex.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToGcsFlex.java#L139 

Added line #L139 was not covered by tests
View more details on Codecov