@@ -141,16 +141,26 @@ void confluentCompatibleMetricsCollectWithoutApacheOnlyAttributes() throws Excep
141141 registerMBean (
142142 "kafka.connect:type=connector-task-metrics,connector=confluent-connector,task=0" ,
143143 mapOf (
144- "status" , "DESTROYED" ,
145- "connector-type" , "sink" ,
146- "batch-size-avg" , 1L ,
147- "batch-size-max" , 2L ,
148- "offset-commit-avg-time-ms" , 5L ,
149- "offset-commit-failure-percentage" , 0.0d ,
150- "offset-commit-max-time-ms" , 6L ,
151- "offset-commit-success-percentage" , 100.0d ,
152- "pause-ratio" , 0.0d ,
153- "running-ratio" , 1.0d ));
144+ "status" ,
145+ "DESTROYED" ,
146+ "connector-type" ,
147+ "sink" ,
148+ "batch-size-avg" ,
149+ 1L ,
150+ "batch-size-max" ,
151+ 2L ,
152+ "offset-commit-avg-time-ms" ,
153+ 5L ,
154+ "offset-commit-failure-percentage" ,
155+ 0.0d ,
156+ "offset-commit-max-time-ms" ,
157+ 6L ,
158+ "offset-commit-success-percentage" ,
159+ 100.0d ,
160+ "pause-ratio" ,
161+ 0.0d ,
162+ "running-ratio" ,
163+ 1.0d ));
154164
155165 startKafkaConnectTelemetry ();
156166
@@ -187,16 +197,26 @@ void apacheSpecificMetricsAreReportedWhenPresent() throws Exception {
187197 registerMBean (
188198 "kafka.connect:type=connector-task-metrics,connector=apache-connector,task=1" ,
189199 mapOf (
190- "connector-type" , "source" ,
191- "status" , "RUNNING" ,
192- "batch-size-avg" , 4L ,
193- "batch-size-max" , 5L ,
194- "offset-commit-avg-time-ms" , 6L ,
195- "offset-commit-failure-percentage" , 0.0d ,
196- "offset-commit-max-time-ms" , 7L ,
197- "offset-commit-success-percentage" , 100.0d ,
198- "pause-ratio" , 0.0d ,
199- "running-ratio" , 1.0d ));
200+ "connector-type" ,
201+ "source" ,
202+ "status" ,
203+ "RUNNING" ,
204+ "batch-size-avg" ,
205+ 4L ,
206+ "batch-size-max" ,
207+ 5L ,
208+ "offset-commit-avg-time-ms" ,
209+ 6L ,
210+ "offset-commit-failure-percentage" ,
211+ 0.0d ,
212+ "offset-commit-max-time-ms" ,
213+ 7L ,
214+ "offset-commit-success-percentage" ,
215+ 100.0d ,
216+ "pause-ratio" ,
217+ 0.0d ,
218+ "running-ratio" ,
219+ 1.0d ));
200220
201221 registerMBean (
202222 "kafka.connect:type=source-task-metrics,connector=apache-connector,task=1" ,
0 commit comments