[flink-connector-kafka] 15/27: [FLINK-29993][conf] Add MetricOptions#forReporter

[martijnvisser]

This is an automated email from the ASF dual-hosted git repository.

martijnvisser pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git

commit af52034ab764a7e61a899afeb348944002241350
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Fri Nov 11 11:43:03 2022 +0100

    [FLINK-29993][conf] Add MetricOptions#forReporter
---
 .../apache/flink/streaming/connectors/kafka/KafkaTestBase.java    | 8 ++------
 1 file changed, 2 insertions(+), 6 deletions(-)

diff --git 
a/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java
 
b/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java
index 37fd81d..b4fd54a 100644
--- 
a/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java
+++ 
b/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java
@@ -18,7 +18,6 @@
 package org.apache.flink.streaming.connectors.kafka;
 
 import org.apache.flink.client.program.ProgramInvocationException;
-import org.apache.flink.configuration.ConfigConstants;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.configuration.MemorySize;
 import org.apache.flink.configuration.MetricOptions;
@@ -131,11 +130,8 @@ public abstract class KafkaTestBase extends TestLogger {
     public static Configuration getFlinkConfiguration() {
         Configuration flinkConfig = new Configuration();
         flinkConfig.set(TaskManagerOptions.MANAGED_MEMORY_SIZE, 
MemorySize.parse("16m"));
-        flinkConfig.setString(
-                ConfigConstants.METRICS_REPORTER_PREFIX
-                        + "my_reporter."
-                        + MetricOptions.REPORTER_FACTORY_CLASS.key(),
-                JMXReporterFactory.class.getName());
+        MetricOptions.forReporter(flinkConfig, "my_reporter")
+                .set(MetricOptions.REPORTER_FACTORY_CLASS, 
JMXReporterFactory.class.getName());
         return flinkConfig;
     }