@Test
public void testGetBrokerConfig() {

    final String brokerId = "1";
    final BrokerConfig brokerConfig = kafkaOperations.getBrokerConfig(brokerId);
    assertNotNull("non-null response", brokerConfig);
    assertFalse("Should not be empty", brokerConfig.getConfigEntries().isEmpty());
    for (final ConfigItem configItem: brokerConfig.getConfigEntries()) {
        assertNotNull(configItem.getName());
    }
}