private def defaultDynamoClient: DynamoDbAsyncClient = DynamoDbAsyncClient.builder.build()

in src/main/scala/com/gu/kinesis/ConsumerConfig.scala [96:109]

• 10 lines of code
• 2 McCabe index (conditional complexity)

  private def defaultDynamoClient: DynamoDbAsyncClient = DynamoDbAsyncClient.builder.build()

  private def defaultCloudwatchClient: CloudWatchAsyncClient = CloudWatchAsyncClient.builder.build()

  private def generateWorkerId: String = UUID.randomUUID().toString
}

private case class ParsedConsumerConfig(
    streamName: String,
    appName: String,
    initialPositionInStreamExtended: Option[InitialPositionInStreamExtended]
)

private object ParsedConsumerConfig {