@Test public void testApplyCommonSettings_noSsl_noSasl() { final ClusterConfig clusterConfig = ClusterConfig.newBuilder() .withBrokerHosts(expectedBrokerHosts) .withUseSsl(false) .withUseSasl(false) .build(); final Map<String, Object> config = util.applyCommonSettings(clusterConfig, consumerId); validateDefaultKeys(config); validateNoSsl(config); validateNoSasl(config); validateNoKey(config, CommonClientConfigs.SECURITY_PROTOCOL_CONFIG); }
public Map<String, Object> applyCommonSettings(final ClusterConfig clusterConfig, final String consumerId) { return applyCommonSettings(clusterConfig, consumerId, new HashMap<>()); }
KafkaClientConfigUtil { public Map<String, Object> applyCommonSettings(final ClusterConfig clusterConfig, final String consumerId) { return applyCommonSettings(clusterConfig, consumerId, new HashMap<>()); } }
KafkaClientConfigUtil { public Map<String, Object> applyCommonSettings(final ClusterConfig clusterConfig, final String consumerId) { return applyCommonSettings(clusterConfig, consumerId, new HashMap<>()); } KafkaClientConfigUtil(final String keyStoreRootPath, final String consumerIdPrefix); }
KafkaClientConfigUtil { public Map<String, Object> applyCommonSettings(final ClusterConfig clusterConfig, final String consumerId) { return applyCommonSettings(clusterConfig, consumerId, new HashMap<>()); } KafkaClientConfigUtil(final String keyStoreRootPath, final String consumerIdPrefix); Map<String, Object> applyCommonSettings(final ClusterConfig clusterConfig, final String consumerId); static List<KafkaSettings> getAllKafkaConsumerProperties(); }
KafkaClientConfigUtil { public Map<String, Object> applyCommonSettings(final ClusterConfig clusterConfig, final String consumerId) { return applyCommonSettings(clusterConfig, consumerId, new HashMap<>()); } KafkaClientConfigUtil(final String keyStoreRootPath, final String consumerIdPrefix); Map<String, Object> applyCommonSettings(final ClusterConfig clusterConfig, final String consumerId); static List<KafkaSettings> getAllKafkaConsumerProperties();  }