@Test public void testApplyCommonSettings_withSsl_withSasl_withTrustStore() { final ClusterConfig clusterConfig = ClusterConfig.newBuilder() .withBrokerHosts(expectedBrokerHosts) .withUseSsl(true) .withKeyStoreFile(expectedKeyStoreFile) .withKeyStorePassword(expectedKeyStorePassword) .withTrustStoreFile(expectedTrustStoreFile) .withTrustStorePassword(expectedTrustStorePassword) .withUseSasl(true) .withSaslMechanism(expectedSaslPlainMechanism) .withSaslPlaintextUsername(expectedSaslUsername) .withSaslPlaintextPassword(expectedSaslPassword) .withSaslJaas(expectedSaslJaas) .build(); final Map<String, Object> config = util.applyCommonSettings(clusterConfig, consumerId); validateDefaultKeys(config); validateSsl(config, "SASL_SSL", false, true); validateSaslPlainMechanism(config, "SASL_SSL"); }
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();  }