FLINK Stream API socketTextStream (имя хоста, порт) действует как клиент
1 Eriko [2017-04-27 17:11:00]
FLINK Stream API socketTextStream (имя хоста, порт) действует как Клиент. то есть нам нужно отправить непрерывный поток на порт, а метод socketTextStream (имя хоста, порт) будет читать входящий поток.
Но мое требование похоже на то, что я хочу использовать FLINK в качестве сервера и искать API, который может слушать из порта. Может ли кто-нибудь иметь API потока FLINK? это решит мою проблему. Заранее спасибо !!!
//
apache-flink
1 ответ
0 David Anderson [2017-05-31 14:38:00]
Там нет поддержки для этого встроенного в Flink, но если вы действительно хотели, чтобы вы могли построить сервер в операторе flatmap или ProcessFunction или реализовать пользовательский Sink.
Тем не менее, это не похоже на хороший способ создания надежной системы (нелегко сделать эту отказоустойчивость или управлять перераспределением без потери данных). Почему бы не потопить результаты Flink во что-то вроде темы Kafka и прикрепить к ней других клиентов?