JayajP

Update BigQuerySinkMetrics for StreamingInserts.

3

Update the following metrics after we insert a batch of rows using BigQuery's InsertAll RPC. ### 1. `RowsAppendedCount` Counter Tracks the status of BigQuery Rows after the batch of InsertAll...

Some notes: - This is effectively a safe rollback of [pr/29482](https://github.com/apache/beam/pull/29482). - We will send this data through DFE instead of WMW. - User Workers are currently not populating these...

Stop using KV as the Key for Histogram Metrics

2

Currenlty, PerWorkerHistograms are in a Map that's keyed by `KV`. After this change the map they're stored in will be Keyed by `MetricName`. Computing a hash/equality for the `KV` object...

[Bug]: Unable to connect to GMK topic using Kafka-client 4.0.0

1

### What happened? I tried running a Dataflow job that reads messages from a Kafka topic using kafka-client 4.0.0 and my reads were silently failing. Downgrading to 3.7.0 caused reads...