@Test public void checkMultipleWarnings() { Kafka kafka = ResourceUtils.createKafka(NAMESPACE, NAME, 1, IMAGE, HEALTH_DELAY, HEALTH_TIMEOUT, Collections.emptyMap(), Collections.emptyMap(), Collections.emptyMap(), new EphemeralStorage(), new EphemeralStorage(), null, null, null, null); KafkaSpecChecker checker = generateChecker(kafka); List<Condition> warnings = checker.run(); assertThat(warnings, hasSize(2)); }
public List<Condition> run() { List<Condition> warnings = new ArrayList<>(); checkKafkaLogMessageFormatVersion(warnings); checkKafkaStorage(warnings); checkZooKeeperStorage(warnings); checkZooKeeperReplicas(warnings); return warnings; }
KafkaSpecChecker { public List<Condition> run() { List<Condition> warnings = new ArrayList<>(); checkKafkaLogMessageFormatVersion(warnings); checkKafkaStorage(warnings); checkZooKeeperStorage(warnings); checkZooKeeperReplicas(warnings); return warnings; } }
KafkaSpecChecker { public List<Condition> run() { List<Condition> warnings = new ArrayList<>(); checkKafkaLogMessageFormatVersion(warnings); checkKafkaStorage(warnings); checkZooKeeperStorage(warnings); checkZooKeeperReplicas(warnings); return warnings; } KafkaSpecChecker(KafkaSpec spec, KafkaCluster kafkaCluster, ZookeeperCluster zkCluster); }
KafkaSpecChecker { public List<Condition> run() { List<Condition> warnings = new ArrayList<>(); checkKafkaLogMessageFormatVersion(warnings); checkKafkaStorage(warnings); checkZooKeeperStorage(warnings); checkZooKeeperReplicas(warnings); return warnings; } KafkaSpecChecker(KafkaSpec spec, KafkaCluster kafkaCluster, ZookeeperCluster zkCluster); List<Condition> run(); }
KafkaSpecChecker { public List<Condition> run() { List<Condition> warnings = new ArrayList<>(); checkKafkaLogMessageFormatVersion(warnings); checkKafkaStorage(warnings); checkZooKeeperStorage(warnings); checkZooKeeperReplicas(warnings); return warnings; } KafkaSpecChecker(KafkaSpec spec, KafkaCluster kafkaCluster, ZookeeperCluster zkCluster); List<Condition> run();  }