spring-cloud-stream-binder-aws-kinesis
spring-cloud-stream-binder-aws-kinesis copied to clipboard
spring-cloud
Spring Cloud Stream binder for AWS Kinesis
**In what version(s) of Spring Cloud Stream Binder for AWS Kinesis are you seeing this issue?** For example: 4.0.0 **Describe the bug** Our project makes use of a `DynamoDbAsyncClient` in...
It seems that the version 4.0.0 of the library removes support of native DynamoDB Streams. My understanding is that this is caused by the migration to KCL v2 that doesn't...
**In what version(s) of Spring Cloud Stream Binder for AWS Kinesis are you seeing this issue?** 2.2.0 **Describe the bug** I am using spring boot application to stream AWS Kinesis....
Spring Boot 3.1.0 spring-cloud-stream-binder-kinesis 4.0.0 Java 17 Localstack 2.1.0 Properties looks like: spring.cloud.stream.bindings.input-in-0.destination=xxx-stream spring.cloud.stream.bindings.input-in-0.group=xxx-group spring.cloud.stream.bindings.input-in-0.content-type=text/plain Tried both of these: spring.cloud.stream.kinesis.bindings.input-in-0.consumer.shard-iterator-type=TRIM_HORIZON spring.cloud.stream.kinesis.bindings.input.consumer.shard-iterator-type=TRIM_HORIZON But my consumer only gets called for new messages....
**In what version(s) of Spring Cloud Stream Binder for AWS Kinesis are you seeing this issue?** 4.0.3 **Describe the bug** According to JetBrain's vulnerability tool there are two vulnerabilities caused...
**In what version(s) of Spring Cloud Stream Binder for AWS Kinesis are you seeing this issue?** 4.0.3 **Describe the issue** We are attempting to gracefully shut down KCL Schedulers. However,...
How to handle backpressure whe using a KCL-KPL application written using cloud-stream-kinesis-binder
**In what version(s) of Spring Cloud Stream Binder for AWS Kinesis are you seeing this issue?** 3.0.0 **Describe the bug** I have an application written using spring-cloud-stream, that connects 2...
Amazon released [KCL version 3](https://aws.amazon.com/about-aws/whats-new/2024/11/kinesis-client-library-reduces-stream-processing-compute-costs/). Please consider switching to the latest version. In the meantime, is it safe to override the version number in the pom.xml of our own project?
I saw events lying in my kinesis consumer which were never getting consumed since multiple days and they would be lost after retention time so I decided to change consumer...
