@Test public void testKafkaCipherSuiteOverride() { Map<String, Object> conf = new HashMap<>(); conf.put("ssl.cipher.suites", "cipher1,cipher2,cipher3"); KafkaConfiguration kc = new KafkaConfiguration(conf.entrySet()); assertThat(kc.asOrderedProperties().asMap().get("ssl.cipher.suites"), is("cipher1,cipher2,cipher3")); }
public OrderedProperties asOrderedProperties() { return options; }
AbstractConfiguration { public OrderedProperties asOrderedProperties() { return options; } }
AbstractConfiguration { public OrderedProperties asOrderedProperties() { return options; } AbstractConfiguration(String configuration, List<String> forbiddenPrefixes);  AbstractConfiguration(String configuration, List<String> forbiddenPrefixes, Map<String, String> defaults);  AbstractConfiguration(Iterable<Map.Entry<String, Object>> jsonOptions, List<String> forbiddenPrefixes);  AbstractConfiguration(Iterable<Map.Entry<String, Object>> jsonOptions, List<String> forbiddenPrefixes, List<String> forbiddenPrefixExceptions);  AbstractConfiguration(Iterable<Map.Entry<String, Object>> jsonOptions, List<String> forbiddenPrefixes, Map<String, String> defaults);  AbstractConfiguration(Iterable<Map.Entry<String, Object>> jsonOptions, List<String> forbiddenPrefixes, List<String> forbiddenPrefixExceptions, Map<String, String> defaults); }
AbstractConfiguration { public OrderedProperties asOrderedProperties() { return options; } AbstractConfiguration(String configuration, List<String> forbiddenPrefixes);  AbstractConfiguration(String configuration, List<String> forbiddenPrefixes, Map<String, String> defaults);  AbstractConfiguration(Iterable<Map.Entry<String, Object>> jsonOptions, List<String> forbiddenPrefixes);  AbstractConfiguration(Iterable<Map.Entry<String, Object>> jsonOptions, List<String> forbiddenPrefixes, List<String> forbiddenPrefixExceptions);  AbstractConfiguration(Iterable<Map.Entry<String, Object>> jsonOptions, List<String> forbiddenPrefixes, Map<String, String> defaults);  AbstractConfiguration(Iterable<Map.Entry<String, Object>> jsonOptions, List<String> forbiddenPrefixes, List<String> forbiddenPrefixExceptions, Map<String, String> defaults); String getConfigOption(String configOption); String getConfigOption(String configOption, String defaultValue); void setConfigOption(String configOption, String value); void removeConfigOption(String configOption); String getConfiguration(); OrderedProperties asOrderedProperties(); }
AbstractConfiguration { public OrderedProperties asOrderedProperties() { return options; } AbstractConfiguration(String configuration, List<String> forbiddenPrefixes);  AbstractConfiguration(String configuration, List<String> forbiddenPrefixes, Map<String, String> defaults);  AbstractConfiguration(Iterable<Map.Entry<String, Object>> jsonOptions, List<String> forbiddenPrefixes);  AbstractConfiguration(Iterable<Map.Entry<String, Object>> jsonOptions, List<String> forbiddenPrefixes, List<String> forbiddenPrefixExceptions);  AbstractConfiguration(Iterable<Map.Entry<String, Object>> jsonOptions, List<String> forbiddenPrefixes, Map<String, String> defaults);  AbstractConfiguration(Iterable<Map.Entry<String, Object>> jsonOptions, List<String> forbiddenPrefixes, List<String> forbiddenPrefixExceptions, Map<String, String> defaults); String getConfigOption(String configOption); String getConfigOption(String configOption, String defaultValue); void setConfigOption(String configOption, String value); void removeConfigOption(String configOption); String getConfiguration(); OrderedProperties asOrderedProperties();  }