Status

Current state: VotingAccepted
Discussion thread: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-128-Enhanced-Fan-Out-for-AWS-Kinesis-Consumers-td42720.html
Voting thread: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/VOTE-FLIP-128-Enhanced-Fan-Out-for-AWS-Kinesis-Consumers-td42846.html
JIRA:

Jira

Released: <TBD>

...

Properties will be validated, and de-/registration will be performed based on the supplied configuration:

flink.stream.efo.registrar	flink.stream.efo.consumerarn.<stream-name>	Registration	Deregistration
lazy	Not required	task startup	task tear-down
eager	Not required	FlinkKinesisConsumer constructor	task tear-down
none	Required	none	none

Stream Consumer Registration

...