@Override
  public KsqlVersionMetrics collectMetrics() {
    final KsqlVersionMetrics metricsRecord = new KsqlVersionMetrics();
    metricsRecord.setTimestamp(TimeUnit.MILLISECONDS.toSeconds(clock.millis()));
    metricsRecord.setConfluentPlatformVersion(AppInfo.getVersion());
    metricsRecord.setKsqlComponentType(moduleType.name());
    metricsRecord.setIsActive(activenessSupplier.get());
    return metricsRecord;
  }
@Test
  public void shouldReportVersion() {
    // When:
    final KsqlVersionMetrics metrics = basicCollector.collectMetrics();

    // Then:
    assertThat(metrics.getConfluentPlatformVersion(), is(AppInfo.getVersion()));
  }