Hong Liang Teoh created FLINK-31986:
---------------------------------------
Summary: Implement Integration test for FLIP-27 DataStreams API
Key: FLINK-31986
URL: https://issues.apache.org/jira/browse/FLINK-31986
Project: Flink
Issue Type: Sub-task
Reporter: Hong Liang Teoh
*What?*
Implement an integration test that uses Kinesalite.
It should spin up FLIP-27 KDS source and test:
* Reading from single shard KDS stream
* Reading from multiple shard KDS stream
* Reading from resharded KDS stream
* Failure modes (stream doesn't exist)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
