Spark Structured Streaming Kinesis Data Streams connector supports both GetRecords and SubscribeToShard (Enhanced Fan-Out, EFO)
26
stars
13
forks
source link
1.5.0 release - 1/ plumb threading model, thread pool size, and rate limit param to KPL #40
Open
penniman26 opened 1 month ago
Issue #, if available: #37
Description of changes:
1.5.0 release (#37)
1/ plumb threading model, thread pool size, and rate limit param to KPL (issue #37)
Tested with
mvn clean install -DskipTests
, deploying the jar, and setting the configsBy submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.