提供一个标准的flink sink scala代码

以下是一个标准的Flink Sink Scala代码，用于将数据流写入Kafka主题：

import org.apache.flink.streaming.api.functions.sink.SinkFunction
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer
import org.apache.flink.streaming.util.serialization.SimpleStringSchema

class KafkaSink(brokerList: String, topic: String) extends SinkFunction[String] {

  lazy val kafkaProducer = new FlinkKafkaProducer[String](
    brokerList, topic, new SimpleStringSchema())

  override def invoke(value: String): Unit = {
    kafkaProducer.send(value)
  }
}

在此示例中，我们使用FlinkKafkaProducer将数据流写入Kafka主题。该类需要传入两个参数：Kafka代理列表和要写入的主题名称。我们还定义了一个invoke方法，该方法将每个收到的数据String发送到Kafka主题中。