@Test
public void testConfig() throws ConfigurationException, InterruptedException {

    Map<String, Object> configuration = new HashMap<>();
    configuration.put("zookeeper.host", "myhost");
    configuration.put("zookeeper.port", "1");
    configuration.put("zookeeper.timeout", "1000");
    DiscoveryConfig config2 = convert(configuration);
    assertEquals("myhost", config2.zookeeper_host());
    zkd.activate(config2, context);
    sem.tryAcquire(10, TimeUnit.SECONDS);
    assertEquals("myhost", config.zookeeper_host());
    assertEquals("1", config.zookeeper_port());
    assertEquals(1000, config.zookeeper_timeout());
}