@Test public void shouldReadSpecificSystemClusterConfiguration() { final BrokerCfg cfg = TestConfigReader.readConfig("cluster-cfg", environment); final ClusterCfg cfgCluster = cfg.getCluster(); assertThat(cfgCluster.getInitialContactPoints()).isEmpty(); assertThat(cfgCluster.getNodeId()).isEqualTo(2); assertThat(cfgCluster.getPartitionsCount()).isEqualTo(3); assertThat(cfgCluster.getReplicationFactor()).isEqualTo(4); assertThat(cfgCluster.getClusterSize()).isEqualTo(5); }
public ClusterCfg getCluster() { return cluster; }
BrokerCfg { public ClusterCfg getCluster() { return cluster; } }
BrokerCfg { public ClusterCfg getCluster() { return cluster; }  }
BrokerCfg { public ClusterCfg getCluster() { return cluster; }  void init(final String brokerBase); void init(final String brokerBase, final Environment environment); NetworkCfg getNetwork(); void setNetwork(final NetworkCfg network); ClusterCfg getCluster(); void setCluster(final ClusterCfg cluster); ThreadsCfg getThreads(); void setThreads(final ThreadsCfg threads); DataCfg getData(); void setData(final DataCfg logs); Map<String, ExporterCfg> getExporters(); void setExporters(final Map<String, ExporterCfg> exporters); EmbeddedGatewayCfg getGateway(); BrokerCfg setGateway(final EmbeddedGatewayCfg gateway); BackpressureCfg getBackpressure(); BrokerCfg setBackpressure(final BackpressureCfg backpressure); Duration getStepTimeout(); void setStepTimeout(final Duration stepTimeout); boolean isExecutionMetricsExporterEnabled(); void setExecutionMetricsExporterEnabled(final boolean executionMetricsExporterEnabled); @Override String toString(); String toJson(); }
BrokerCfg { public ClusterCfg getCluster() { return cluster; }  void init(final String brokerBase); void init(final String brokerBase, final Environment environment); NetworkCfg getNetwork(); void setNetwork(final NetworkCfg network); ClusterCfg getCluster(); void setCluster(final ClusterCfg cluster); ThreadsCfg getThreads(); void setThreads(final ThreadsCfg threads); DataCfg getData(); void setData(final DataCfg logs); Map<String, ExporterCfg> getExporters(); void setExporters(final Map<String, ExporterCfg> exporters); EmbeddedGatewayCfg getGateway(); BrokerCfg setGateway(final EmbeddedGatewayCfg gateway); BackpressureCfg getBackpressure(); BrokerCfg setBackpressure(final BackpressureCfg backpressure); Duration getStepTimeout(); void setStepTimeout(final Duration stepTimeout); boolean isExecutionMetricsExporterEnabled(); void setExecutionMetricsExporterEnabled(final boolean executionMetricsExporterEnabled); @Override String toString(); String toJson();  }