diff --git a/amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/MultiLangDaemonConfigTest.java b/amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/MultiLangDaemonConfigTest.java index 93eb2743..aa46f431 100644 --- a/amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/MultiLangDaemonConfigTest.java +++ b/amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/MultiLangDaemonConfigTest.java @@ -198,6 +198,11 @@ public class MultiLangDaemonConfigTest { } } + /** + * Test the loading of a "real" properties file. This test should catch + * any issues which might arise if there is a discrepancy between reality + * and mocking. + */ @Test public void testActualPropertiesFile() throws Exception { new MultiLangDaemonConfig(FILENAME); diff --git a/amazon-kinesis-client-multilang/src/main/resources/multilang.properties b/amazon-kinesis-client-multilang/src/test/resources/multilang.properties similarity index 90% rename from amazon-kinesis-client-multilang/src/main/resources/multilang.properties rename to amazon-kinesis-client-multilang/src/test/resources/multilang.properties index 46c9e2da..34cb0c1a 100644 --- a/amazon-kinesis-client-multilang/src/main/resources/multilang.properties +++ b/amazon-kinesis-client-multilang/src/test/resources/multilang.properties @@ -45,49 +45,49 @@ regionName = us-east-1 # will be regarded as having problems and it's shards will be assigned to other workers. # For applications that have a large number of shards, this msy be set to a higher number to reduce # the number of DynamoDB IOPS required for tracking leases -#failoverTimeMillis = 10000 +failoverTimeMillis = 10000 # A worker id that uniquely identifies this worker among all workers using the same applicationName # If this isn't provided a MultiLangDaemon instance will assign a unique workerId to itself. -#workerId = +workerId = "workerId" # Shard sync interval in milliseconds - e.g. wait for this long between shard sync tasks. -#shardSyncIntervalMillis = 60000 +shardSyncIntervalMillis = 60000 # Max records to fetch from Kinesis in a single GetRecords call. -#maxRecords = 10000 +maxRecords = 10000 # Idle time between record reads in milliseconds. -#idleTimeBetweenReadsInMillis = 1000 +idleTimeBetweenReadsInMillis = 1000 # Enables applications flush/checkpoint (if they have some data "in progress", but don't get new data for while) -#callProcessRecordsEvenForEmptyRecordList = false +callProcessRecordsEvenForEmptyRecordList = false # Interval in milliseconds between polling to check for parent shard completion. # Polling frequently will take up more DynamoDB IOPS (when there are leases for shards waiting on # completion of parent shards). -#parentShardPollIntervalMillis = 10000 +parentShardPollIntervalMillis = 10000 # Cleanup leases upon shards completion (don't wait until they expire in Kinesis). # Keeping leases takes some tracking/resources (e.g. they need to be renewed, assigned), so by default we try # to delete the ones we don't need any longer. -#cleanupLeasesUponShardCompletion = true +cleanupLeasesUponShardCompletion = true # Backoff time in milliseconds for Amazon Kinesis Client Library tasks (in the event of failures). -#taskBackoffTimeMillis = 500 +taskBackoffTimeMillis = 500 # Buffer metrics for at most this long before publishing to CloudWatch. -#metricsBufferTimeMillis = 10000 +metricsBufferTimeMillis = 10000 # Buffer at most this many metrics before publishing to CloudWatch. -#metricsMaxQueueSize = 10000 +metricsMaxQueueSize = 10000 # KCL will validate client provided sequence numbers with a call to Amazon Kinesis before checkpointing for calls # to RecordProcessorCheckpointer#checkpoint(String) by default. -#validateSequenceNumberBeforeCheckpointing = true +validateSequenceNumberBeforeCheckpointing = true # The maximum number of active threads for the MultiLangDaemon to permit. # If a value is provided then a FixedThreadPool is used with the maximum # active threads set to the provided value. If a non-positive integer or no # value is provided a CachedThreadPool is used. -#maxActiveThreads = 0 +maxActiveThreads = -1