class KafkaAdminClient implements Closeable {

    public int getTopicPartitions(String topic) {
        if (StringUtils.isBlank(topic))
            throw new IllegalArgumentException("topic cannot be null, empty or blank");

        LOG.debug("Fetching topic partition count for topic [{}]", topic);
        return getPartitions(Collections.singleton(topic)).size();
    }

    public  KafkaAdminClient(Properties properties);

}