@Test
public void testApplyCommonSettings_noSsl_withSasl_customMechanism() {

    final ClusterConfig clusterConfig = ClusterConfig.newBuilder()
        .withBrokerHosts(expectedBrokerHosts)
        .withUseSsl(false)
        .withUseSasl(true)
        .withSaslMechanism(expectedSaslCustomMechanism)
        .withSaslJaas(expectedSaslJaas)
        .build();
    final Map<String, Object> config = util.applyCommonSettings(clusterConfig, consumerId);
    // Validate
    validateDefaultKeys(config);
    validateNoSsl(config);
    validateSaslCustomMechanism(config);
}