@Test public void shouldOverrideClusterSizeViaEnvironment() { environment.put(ZEEBE_BROKER_CLUSTER_CLUSTER_SIZE, "2"); final BrokerCfg cfg = TestConfigReader.readConfig("cluster-cfg", environment); final ClusterCfg cfgCluster = cfg.getCluster(); assertThat(cfgCluster.getClusterSize()).isEqualTo(2); }
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();  }