Я пытаюсь получить доступ к одной или нескольким темам 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)