Hi Shuiqiang, Thanks for letting me know. Feel free to send any beginner level contributions for this effort my way π .
Best, kevin From: Shuiqiang Chen <acqua....@gmail.com> Date: Wednesday, March 24, 2021 at 10:31 PM To: "Bohinski, Kevin" <kevin_bohin...@comcast.com> Cc: user <user@flink.apache.org> Subject: [EXTERNAL] Re: PyFlink DataStream Example Kafka/Kinesis? Hi Kevin, Kinesis connector is not supported yet in Python DataStream API. We will add it in the future. Best, Shuiqiang Bohinski, Kevin <kevin_bohin...@comcast.com<mailto:kevin_bohin...@comcast.com>> δΊ2021εΉ΄3ζ25ζ₯ε¨ε δΈε5:03ειοΌ Is there a kinesis example? From: "Bohinski, Kevin" <kevin_bohin...@comcast.com<mailto:kevin_bohin...@comcast.com>> Date: Wednesday, March 24, 2021 at 4:40 PM To: "Bohinski, Kevin" <kevin_bohin...@comcast.com<mailto:kevin_bohin...@comcast.com>> Subject: Re: PyFlink DataStream Example Kafka/Kinesis? Nevermind, found this for anyone else looking: https://github.com/apache/flink/blob/master/flink-end-to-end-tests/flink-python-test/python/datastream/data_stream_job.py<https://urldefense.com/v3/__https:/github.com/apache/flink/blob/master/flink-end-to-end-tests/flink-python-test/python/datastream/data_stream_job.py__;!!CQl3mcHX2A!QFaB5DO1ZU_Sx8v59FCwTcqH2lAH3CrM8-jFD1xIuUN-LvDep2fAnOlpFTwBV7CSMLggLw$> From: "Bohinski, Kevin" <kevin_bohin...@comcast.com<mailto:kevin_bohin...@comcast.com>> Date: Wednesday, March 24, 2021 at 4:38 PM To: user <user@flink.apache.org<mailto:user@flink.apache.org>> Subject: PyFlink DataStream Example Kafka/Kinesis? Hi, Is there an example kafka/kinesis source or sink for the PyFlink DataStream API? Best, kevin