[Flink Support] Kafka

Write Kafka

import java.util.Properties
import org.apache.flink.api.common.serialization.SimpleStringSchema
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer
val stream: DataStream[String] = ...
val producerConfig = new Properties()
producerConfig.put("bootstrap.servers", "localhost:9092,localhost2:9092")
stream.addSink(new FlinkKafkaProducer[String]("topic", new SimpleStringSchema(), producerConfig))