override def initialize()

in src/main/scala/com/gu/contentapi/firehose/kinesis/SingleEventProcessor.scala [30:33]

• 4 lines of code
• 1 McCabe index (conditional complexity)

  override def initialize(input: InitializationInput): Unit = {
    this.shardId = input.shardId()
    logger.info(s"Initialized an event processor for shard $shardId")
  }