Я использую Flume для сбора потоковых данных из Кафки в HDFS.
Но источник данных может стать множественным.
Поэтому мне интересно, смогу ли я построить систему сбора данных:
Кафка / Kinesis / Pub / Sub -> Flume -> HDFS (хранилище) / Flink (обработка).
Но, похоже, я не могу найти данные о том, как подключить Flume к Kinesis, pub / sub. Это выполнимо? Любая помощь приветствуется.