luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Relocated multilang.properties from main/resources to test/resources

Browse source
This commit is contained in:
stair 2023-08-07 15:47:24 -04:00
parent 6809f29726
commit 6fc3faec81
2 changed files with 18 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/MultiLangDaemonConfigTest.java
View file

@ -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 @Test
public void testActualPropertiesFile() throws Exception { public void testActualPropertiesFile() throws Exception {
new MultiLangDaemonConfig(FILENAME); new MultiLangDaemonConfig(FILENAME);

26
amazon-kinesis-client-multilang/src/main/resources/multilang.properties → amazon-kinesis-client-multilang/src/test/resources/multilang.properties
View file

@ -45,49 +45,49 @@ regionName = us-east-1
# will be regarded as having problems and it's shards will be assigned to other workers. # 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 # 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 # 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 # 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. # 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. # 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. # Max records to fetch from Kinesis in a single GetRecords call.
#maxRecords = 10000 maxRecords = 10000
# Idle time between record reads in milliseconds. # 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) # 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. # 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 # Polling frequently will take up more DynamoDB IOPS (when there are leases for shards waiting on
# completion of parent shards). # completion of parent shards).
#parentShardPollIntervalMillis = 10000 parentShardPollIntervalMillis = 10000
# Cleanup leases upon shards completion (don't wait until they expire in Kinesis). # 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 # 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. # 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). # 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. # 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. # 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 # KCL will validate client provided sequence numbers with a call to Amazon Kinesis before checkpointing for calls
# to RecordProcessorCheckpointer#checkpoint(String) by default. # to RecordProcessorCheckpointer#checkpoint(String) by default.
#validateSequenceNumberBeforeCheckpointing = true validateSequenceNumberBeforeCheckpointing = true
# The maximum number of active threads for the MultiLangDaemon to permit. # The maximum number of active threads for the MultiLangDaemon to permit.
# If a value is provided then a FixedThreadPool is used with the maximum # 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 # active threads set to the provided value. If a non-positive integer or no
# value is provided a CachedThreadPool is used. # value is provided a CachedThreadPool is used.
#maxActiveThreads = 0 maxActiveThreads = -1