Is spring-cloud-stream-binder already supports using Kinesis enhanced fan-out?

Question

I can't find any documentation that explains how to integrate with Kinesis enhanced fan-out. Still, is there such a possibility?

example of my configuration:

spring:
   clouds:
     streams:
       bindings:
         consumeRequest-in-0:
           destination: dev-kinesis
           content-type: application/json
           group: dev-kinesis-grm
       functions:
         definition: consumeRequest
       kinesis:
         bindings:
           consumeRequest-in-0:
             consumer:
               listener-mode: batch
               records-limit: 100
               shard-iterator-type: LATEST

score 0 · Accepted Answer · answered Apr 18 '23 at 15:22

0

we do support it since version 4.0.0 of this Kinesis Binder: https://spring.io/blog/2023/03/27/spring-integration-for-aws-3-0-0-m2-and-spring-cloud-stream-kinesis-binder-4.

It is only a part of KCL configuration though. We couldn't do anything until we have updated to the latest AWS Java SDK v2.

We are going to release GA somewhere in May.

answered Apr 18 '23 at 15:22

Artem Bilan

113,505
11
91
118

Thank you! It is really helpful. Does it need special settings to register for Kinesis as a fan-out? – Pumiki Apr 19 '23 at 06:39
Just only this one: `kplKclEnabled=true` – Artem Bilan Apr 19 '23 at 12:59

Is spring-cloud-stream-binder already supports using Kinesis enhanced fan-out?

1 Answers1