Hi everyone, I am trying to get started with Python on Flink-cluster runner, to build a pipeline that reads data from Kafka and write to S3 in parquet format. I tried to search on Beam website, but could not find any example (even for the basic word count). E.g, in this page https://beam.apache.org/get-started/wordcount-example/, in all Python - Flink-cluster sections, there's no content but "This runner is not yet available for the Python SDK."
At this point in time, is that possible to create such a pipeline? From all the slides / videos, it seems feasible. But, could you please lead me to some step-by-step guide? Thanks and best regards, Averell
