Description of changes:
The EFO Kinesis connector will register and de-register stream consumers based on the configured registration strategy. When EAGER is used, the client (usually job manager) will register the consumer and then the task managers will de-register the consumer when job stops/fails. If the job is configured to restart on fail, then the consumer will not exist and the job will continuously fail over.
I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.
Issue #: FLINK-24431
Description of changes: The EFO Kinesis connector will register and de-register stream consumers based on the configured registration strategy. When EAGER is used, the client (usually job manager) will register the consumer and then the task managers will de-register the consumer when job stops/fails. If the job is configured to restart on fail, then the consumer will not exist and the job will continuously fail over.
I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.