Artem Bilan

Looks like a duplication of: https://github.com/spring-projects/spring-framework/issues/22009. We might still reconsider this for current state of things.

I think this one would be a natural evolution after https://github.com/spring-projects/spring-integration-aws/issues/249. So, we would expose respective back-pressure configuration properties and handle them in the binder for KPL binding configuration. Thanks

Well, that would justify a new major version for `spring-integration-aws` and, respectively, new major for this Kinesis Binder project. That is going to be a plan for the next year....

Yeah... Taking that back. When I added: ``` adapter.setLeaseManagementConfigCustomizer(leaseManagementConfig -> leaseManagementConfig.workerUtilizationAwareAssignmentConfig().disableWorkerMetrics(true)); ``` and increased receive timeout, I got tests passed. So, looks like KCL v3 is just a drop-in dependency!

Our logic is like this: ``` @Override public void shutdownRequested(ShutdownRequestedInput shutdownRequestedInput) { logger.info("Scheduler is shutting down; checkpointing..."); try { shutdownRequestedInput.checkpointer().checkpoint(); } catch (ShutdownException | InvalidStateException ex) { logger.error(ex, "Exception while...

Well, that's question not to this project. We just follow an API and its description: ``` /** * Called when the Scheduler has been requested to shutdown. This is called...

I believer both of those reports are false-positive since we talk here about a *producer*, so even if that KPL uses Ion for serialization, there is definitely no **deserialization** to...

Closed as non-relevant to the project.

Would be great if you can share more info about that `NullPointerException`. I mean what is exactly stack trace. Plus, keep in mind that `2.2.x` version of this project is...

Thank for the report! We don't find this as an easy fix since there is going to be too many moving parts with those `add/remove([indext])` in the `CompositeRecordInterceptor` and `AbstractMessageListenerContainer`....