Skip to content

Clean up terminated shards before expiry #248

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
istreeter opened this issue Dec 20, 2021 · 1 comment
Closed

Clean up terminated shards before expiry #248

istreeter opened this issue Dec 20, 2021 · 1 comment

Comments

@istreeter
Copy link
Contributor

The KinesisClientLibConfiguration takes a parameter cleanupTerminatedShardsBeforeExpiry, described here.

The default in the KinesisClientLibConfiguration is true. But the default in kinesis connector configuration is false. In the upgrade from version 1.0.0 to 2.1.0 we changed to use the kinesis connector default, instead of the kinesis client default.

I believe this explains an anomaly we have seen in cloudwatch metrics, in which it appears streams are lagging when they are not, especially after resharding events.

We should also check what other parameters got accidentally changed between versions 1.0.0 and 2.1.0.

@istreeter
Copy link
Contributor Author

Update: I confirmed that using true for cleanupTerminatedShardsBeforeExpiry fixes the problem in cloudwatch metrics, in which it appears streams are lagging when they are not, especially after resharding events.

My description earlier was not completely correct though: we had it set to false even in version 1.0.0. However, the KCL libraries are vastly different between version 1.7 and 1.14, so it is not a surprise to me that we didn't see this problem in s3 loader 1.0.0.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant