import org.apache.kafka.clients.admin.AdminClient;
 
public interface KafkaClientSupplier {
    // other existing APIs

    /**
     * Create a {@link AdminClient} which is used tofor readinternal records to restore {@link StateStore}stopic management.
     *
     * @param config {@link StreamsConfig#getRestoreConsumerConfigs(String) restore consumer config} which is supplied
     *               Supplied by the {@link StreamsConfig} given to the {@link KafkaStreams}
     * @return an instance of Kafka{@link consumerAdminClient}
     */
    AdminClient getAdminCLient(final Map<String, Object> config);
}