Metrics { public void uploadedEvents(long eventCount) { uploadedEvents.mark(eventCount); } @Autowired  Metrics(MetricRegistry registry); void consumedBytes(long byteCount); void uploadedBytes(long byteCount); void uploadedEvents(long eventCount); void offsetHighwaterMark(int partition, long offset);  }
@Test public void uploadedEvents() { when(metricRegistry.meter(Metrics.UPLOADED_EVENTS)).thenReturn(meter); new Metrics(metricRegistry).uploadedEvents(1L); verify(meter).mark(1L); }