Flink 1.6. Источники данных Python Streaming API (Kafka Consumer) - PullRequest
0 голосов
/ 07 сентября 2018

Я пытаюсь получить доступ к одной или нескольким темам Kafka с помощью Python Streaming API в Flink 1.6

Кто-нибудь делал доступ к Kafka с Python?

В официальной документации Flink естьнекоторые примеры, но я не мог видеть источник Кафки.

Любая помощь / совет по чтению Кафки в python приветствуется.

Спасибо.

Примеры потоковых источников данных

env  = factory.get_execution_environment()

\# read text file from local files system
localLiens = env.read_text("file:///path/to/my/textfile")

\# read text file from a HDFS running at nnHost:nnPort
hdfsLines = env.read_text("hdfs://nnHost:nnPort/path/to/my/textfile")

\# create a set from some given elements
values = env.from_elements("Foo", "bar", "foobar", "fubar")

\# generate a number sequence
numbers = env.generate_sequence(1, 10000000)
...