From 5a878637a41141cab7d91cce143d99544ffd6809 Mon Sep 17 00:00:00 2001 From: Vladimir Orany Date: Fri, 28 Jul 2023 16:39:19 +0200 Subject: [PATCH] use pay per request for DynamoDB tables (#127) --- .../grails/plugin/awssdk/kinesis/AbstractClientService.groovy | 2 ++ 1 file changed, 2 insertions(+) diff --git a/grails-aws-sdk-kinesis/src/main/groovy/grails/plugin/awssdk/kinesis/AbstractClientService.groovy b/grails-aws-sdk-kinesis/src/main/groovy/grails/plugin/awssdk/kinesis/AbstractClientService.groovy index 3117d2a..2f32431 100644 --- a/grails-aws-sdk-kinesis/src/main/groovy/grails/plugin/awssdk/kinesis/AbstractClientService.groovy +++ b/grails-aws-sdk-kinesis/src/main/groovy/grails/plugin/awssdk/kinesis/AbstractClientService.groovy @@ -6,6 +6,7 @@ import com.amazonaws.auth.AWSCredentialsProvider import com.amazonaws.auth.DefaultAWSCredentialsProviderChain import com.amazonaws.regions.Region import com.amazonaws.regions.ServiceAbbreviations +import com.amazonaws.services.dynamodbv2.model.BillingMode import com.amazonaws.services.kinesis.AmazonKinesisClient import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorFactory import com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStream @@ -87,6 +88,7 @@ abstract class AbstractClientService { .withRegionName(region.name) .withInitialPositionInStream(InitialPositionInStream.LATEST) .withIdleTimeBetweenReadsInMillis(idleTimeBetweenReadsInMillis) + .withBillingMode(BillingMode.PAY_PER_REQUEST) // Create a new worker for each stream Worker worker = new Worker(recordProcessorFactory, kclConfig)