Я новичок в нетти.
Я пытаюсь прослушать тему kafka и создать соединение с BootstrapClient на основе информации из этой темы, затем выполнить несколько вызовов через одно соединение и накапливать ответы в обработчике - пока все хорошо, у меня есть нет проблем здесь Затем мне нужно отправить результат в другую тему кафки.
Можно ли закрыть канал и вернуть объект закрытому списку каналов? - Я хочу, чтобы толчок к теме кафки был за пределами (канала) конвейера.
П.С .: Я уже знаю, что вы можете поместить издателя в обработчик и отправить туда объект.