class KafkaOperations implements AutoCloseable {

    public TopicConfig getTopicConfig(final String topic) {
        final ConfigResource configResource = new ConfigResource(ConfigResource.Type.TOPIC, topic);
        return new TopicConfig(describeResource(configResource));
    }

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

}