diff --git a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/application/TestConsumer.java b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/application/TestConsumer.java index 8d3179be..67d476fa 100644 --- a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/application/TestConsumer.java +++ b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/application/TestConsumer.java @@ -151,7 +151,9 @@ public class TestConsumer { checkpointConfig = configsBuilder.checkpointConfig(); coordinatorConfig = configsBuilder.coordinatorConfig(); leaseManagementConfig = configsBuilder.leaseManagementConfig() - .initialPositionInStream(InitialPositionInStreamExtended.newInitialPosition(consumerConfig.getInitialPosition())) + .initialPositionInStream( + InitialPositionInStreamExtended.newInitialPosition(consumerConfig.getInitialPosition()) + ) .initialLeaseTableReadCapacity(50).initialLeaseTableWriteCapacity(50); lifecycleConfig = configsBuilder.lifecycleConfig(); processorConfig = configsBuilder.processorConfig();