class KafkaOperations implements AutoCloseable {

    public BrokerConfig getBrokerConfig(final String brokerId) {
        final ConfigResource configResource = new ConfigResource(ConfigResource.Type.BROKER, brokerId);
        return new BrokerConfig(describeResource(configResource));
    }

    public  KafkaOperations(final AdminClient adminClient, final KafkaConsumer<String, String> consumerClient);

}