KCLWorkerConfig.kt

 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)
    }