Skip to content

Instantly share code, notes, and snippets.

@mkurian
Last active November 10, 2019 20:14
Show Gist options
  • Save mkurian/d1fc300d4060945fe97148d6ae1a331e to your computer and use it in GitHub Desktop.
Save mkurian/d1fc300d4060945fe97148d6ae1a331e to your computer and use it in GitHub Desktop.
KCL worker for DynamoDB
val fooStreamWorker = Worker.Builder()
.recordProcessorFactory(fooStreamRecordProcessorFactory)
.config(kclConfig(fooStreamConfig)).kinesisClient(dynamoDBStreamsAdapterClient())
.build()
val fooWorker = Thread(fooStreamWorker)
fooWorker.start()
fun dynamoDBStreamsAdapterClient(): AmazonDynamoDBStreamsAdapterClient {
return AmazonDynamoDBStreamsAdapterClient(awsAuth.credentialsProvider())
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment