createWorker.kt

        
        for (i in 1..9) {
            val workerId = "workerId-$i"
            val kclConfig = KinesisClientLibConfiguration("fooWorker",
                    streamConfig.streamArn, awsAuth.credentialsProvider(), workerId)
                    .withMaxRecords(streamConfig.maxRecords)
                    .withInitialPositionInStream(InitialPositionInStream.valueOf(streamConfig.streamPosition))
                    .withRegionName(ddbStreamConfigProperties.region)
                    .withDynamoDBEndpoint(ddbStreamConfigProperties.dynamoDBEndpoint)
                    .withCallProcessRecordsEvenForEmptyRecordList(true)
                    .withParentShardPollIntervalMillis(3000)
            val streamWorker = Worker.Builder()
                    .recordProcessorFactory(recordProcessorFactory)
                    .config(kclConfig).kinesisClient(AmazonDynamoDBStreamsAdapterClient(awsAuth.credentialsProvider()))
                    .build()
            val workerThread = Thread(streamWorker)
            workerThread.name = "$workerId-${workerThread.name}"
            workerThread.start()
        }