Veronica Wasson

[Feature Request]: Improve Managed API to avoid redundant `PCollectionRowTuple` calls

1

### What would you like to happen? The Managed transform API returns `PCollectionRowTuple`s, which requires extra calls when building a pipeline. Specifically, for reads we have to call `PCollectionRowTuple.empty(pipeline).apply ......

## Description - Bump Apache Beam version - Update Iceberg snippets to latest API - Minor fixes to comments ## Checklist - [ ] I have followed [Sample Format Guide](https://github.com/GoogleCloudPlatform/java-docs-samples/blob/main/SAMPLE_FORMAT.md)...

docs(samples): Add Dataflow snippet to read from multiple Kafka topics

1

## Description Shows how to build a Dataflow pipeline that reads from multiple Kafka topics, filters based on the topic name, and performs different application logic per topic. Snippet bug:...

docs(samples): Add Dataflow snippet for reading from Cloud Storage

1

## Description Adds a snippet that shows how to reading from a Cloud Storage file into Dataflow. Snippet bug: b/340947448 Related doc bug: b/337851367 I structured this snippet similarly to...

docs(samples): Read multiple Kafka topics from Dataflow

1

## Description Add a code snippet that shows how to read from multiple Kafka topics in a Dataflow pipeline. This snippet shows a recommended pattern for handling messages from several...

[Bug]: Cannot create DLQ table through Console UI workflow

1

### Related Template(s) PubSub_Subscription_to_BigQuery ### Template Version latest ### What happened? The description of the `outputDeadletterTable` parameter says "If the table doesn't exist, it is created during pipeline execution" This...

### Related Template(s) Kafka_to_Kafka ### Template Version latest ### What happened? The description for `readBootstrapServerAndTopic` includes this example string: `localhost:9092;topic1,topic2`, which implies the template can read from multiple source topics....

Fix description of Pub/Sub subscription parameter

1

Bug Fix - See b/390088746