override def handle()

in quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/KafkaSourceApp.scala [24:30]

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

  override def handle(): Unit = {

    KafkaSource().getDataStream[String]()
      .map(_.value)
      .print()

  }