class BasicCollector extends Collector {

  @Override
  public GenericContainer collectMetrics() {
    KsqlVersionMetrics metricsRecord = new KsqlVersionMetrics();
    metricsRecord.setTimestamp(timeUtils.nowInUnixTime());
    metricsRecord.setConfluentPlatformVersion(Version.getVersion());
    metricsRecord.setKsqlComponentType(moduleType.name());
    return metricsRecord;
  }

  public  BasicCollector(KsqlModuleType moduleType, TimeUtils timeUtils);

}