перевести все с Web на WebFlux, и был такой метод :
T (Request request) {
String topicName = (String) request.getParam("topicName");
Integer partitions = request ..
String test = request...
AdminClient adminClient = ...
AdminClient.createTopics(topicName)
}
Куда засовывать этот синхронный код? Нормально ли в каком-нибудь Flux.just(... {
Вот сюда засовывать все это
}
Может есть у кого-нибудь схожее
Такие блоки кода обычно выполняются в коллбэках map / flatMap, то есть можно: Mono.empty<Void>().map(() -> { }) Либо: Mono.fromRunnable(() -> { })
Обсуждают сегодня