Re: KafkaIO metric publishing

2024-06-19 Thread XQ Hu via user
Is your job a Dataflow Template job? The error is caused by https://github.com/apache/beam/blob/master/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/DataflowTemplateJob.java#L55 . So basically DataflowTemplateJob does not support metrics. On Wed, Jun

KafkaIO metric publishing

2024-06-19 Thread Lahiru Ginnaliya Gamathige
Hi Users, In Google Cloud monitoring there is a limit of 100 metrics and when we are using KafkaIO, the library publishes a bunch of metrics per topic. With our use we will easily run out of 100 metric limit. We want to stop KafkaIO from publishing metrics and I do not see this is configurable.