class KafkaAdminFactory {

    public AdminClient create(final ClusterConfig clusterConfig, final String clientId) {
        // Create a map
        final Map<String, Object> config = configUtil.applyCommonSettings(clusterConfig, clientId);

        // Build admin client.
        return KafkaAdminClient.create(config);
    }

    public  KafkaAdminFactory(final KafkaClientConfigUtil configUtil);

}