You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
The newer versions of transformer-kinesis are able to scale up to multiple concurrent instances. Therefore it must be resilient to autoscaling events, in which KCL workers steal leases from each other.
This is similar to snowplow/enrich#649 where it is explained in detail.
The newer versions of transformer-kinesis are able to scale up to multiple concurrent instances. Therefore it must be resilient to autoscaling events, in which KCL workers steal leases from each other.
The simple solution is to catch and handle a ShutdownException when checkpointing a record
The text was updated successfully, but these errors were encountered: