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

Reply via email to