@Test
public void testToConsumerConfig() {

    val config = ConfigFactory.load("consumer.conf");
    val props = ConfigUtil.toConsumerConfig(config);
    assertEquals(BOOTSTRAP_SERVERS, props.getProperty(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG));
    assertEquals(GROUP_ID, props.getProperty(ConsumerConfig.GROUP_ID_CONFIG));
    assertEquals(KEY_DESER, props.getProperty(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG));
    assertEquals(VALUE_DESER, props.getProperty(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG));
}