Simple example demonstrating a problem with Enhanced Fan-Out KCL Consumers against Localstack
Based on https://docs.aws.amazon.com/streams/latest/dev/building-enhanced-consumers-kcl-java.html but tweaked to work with Localstack.
Duplication steps:
- Start localstack:
docker-compose up --build -d- Create a Kinesis stream:
aws kinesis create-stream --stream-name efo-test --profile localstack- Run the application and wait for the errors to happen. The time it takes for the error to happen is equal to the
apiCallTimeoutsetting on the Kinesis client