AdminClientService.java 225 B

12345678910
  1. package com.provectus.kafka.ui.service;
  2. import com.provectus.kafka.ui.model.KafkaCluster;
  3. import reactor.core.publisher.Mono;
  4. public interface AdminClientService {
  5. Mono<ReactiveAdminClient> get(KafkaCluster cluster);
  6. }