Skip to content

Instantly share code, notes, and snippets.

@mkurian
Last active Nov 10, 2019
Embed
What would you like to do?
fun kclConfig(streamConfig: StreamConfigProperties): KinesisClientLibConfiguration {
return KinesisClientLibConfiguration(streamConfig.applicationName,
streamConfig.streamArn, awsAuth.credentialsProvider(), streamConfig.workerId)
.withMaxRecords(streamConfig.batchSize)
.withIdleTimeBetweenReadsInMillis(streamConfig.pollingFrequency)
.withInitialPositionInStream(InitialPositionInStream.valueOf(streamConfig.streamPosition))
.withRegionName(streamConfig.region)
.withDynamoDBEndpoint(streamConfig.dynamoDBEndpoint)
.withCallProcessRecordsEvenForEmptyRecordList(true)
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment