@Test public void testKafkaBrokerId() { assertEquals(Integer.parseInt(propertyParser.getProperty(ConfigVars.KAFKA_TEST_BROKER_ID_KEY)), (int) kafkaLocalBroker.getKafkaBrokerId()); }
public Integer getKafkaBrokerId() { return kafkaBrokerId; }
KafkaLocalBroker implements MiniCluster { public Integer getKafkaBrokerId() { return kafkaBrokerId; } }
KafkaLocalBroker implements MiniCluster { public Integer getKafkaBrokerId() { return kafkaBrokerId; } private  KafkaLocalBroker(Builder builder); }
KafkaLocalBroker implements MiniCluster { public Integer getKafkaBrokerId() { return kafkaBrokerId; } private  KafkaLocalBroker(Builder builder); String getKafkaHostname(); Integer getKafkaPort(); Integer getKafkaBrokerId(); Properties getKafkaProperties(); String getKafkaTempDir(); String getZookeeperConnectionString(); @Override void start(); @Override void stop(); @Override void stop(boolean cleanUp); @Override void configure(); @Override void cleanUp(); }
KafkaLocalBroker implements MiniCluster { public Integer getKafkaBrokerId() { return kafkaBrokerId; } private  KafkaLocalBroker(Builder builder); String getKafkaHostname(); Integer getKafkaPort(); Integer getKafkaBrokerId(); Properties getKafkaProperties(); String getKafkaTempDir(); String getZookeeperConnectionString(); @Override void start(); @Override void stop(); @Override void stop(boolean cleanUp); @Override void configure(); @Override void cleanUp();  }