kafka-ui/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/AdminClientService.java

package com.provectus.kafka.ui.service;

import com.provectus.kafka.ui.model.KafkaCluster;
import java.util.Optional;
import reactor.core.publisher.Mono;

public interface AdminClientService {

  Mono<ReactiveAdminClient> get(KafkaCluster cluster);

}