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> 于2021年3月25日周四 上午5:03写道： > Is there a kinesis example? > > > > *From: *"Bohinski, Kevin" <kevin_bohin...@comcast.com> > *Date: *Wednesday, March 24, 2021 at 4:40 PM > *To: *"Bohinski, Kevin" <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 > > > > *From: *"Bohinski, Kevin" <kevin_bohin...@comcast.com> > *Date: *Wednesday, March 24, 2021 at 4:38 PM > *To: *user <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 >
