class KafkaAdminFactory {

    public KafkaConsumer<String, String> createConsumer(final ClusterConfig clusterConfig, final String clientId) {
        // Create config
        final Map<String, Object> config = getConsumerConfig(clusterConfig, clientId);

        // Create consumer
        return new KafkaConsumer<>(config);
    }

    public  KafkaAdminFactory(final KafkaClientConfigUtil configUtil);

}