建站
咨詢
售后
建站咨詢
新聞中心
這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷解決方案
flinkconnector之FlinkKafkaProducer的示例代碼
這篇文章給大家分享的是有關(guān)flink connector之FlinkKafkaProducer的示例代碼的內(nèi)容。小編覺(jué)得挺實(shí)用的，因此分享給大家做個(gè)參考，一起跟隨小編過(guò)來(lái)看看吧。
專業(yè)從事企業(yè)網(wǎng)站建設(shè)和網(wǎng)站設(shè)計(jì)服務(wù)，包括網(wǎng)站建設(shè)、申請(qǐng)域名、雅安服務(wù)器托管、企業(yè)郵箱、微信公眾號(hào)開(kāi)發(fā)、微信支付寶成都小程序開(kāi)發(fā)、成都APP應(yīng)用開(kāi)發(fā)、軟件開(kāi)發(fā)、等服務(wù)。公司始終通過(guò)不懈的努力和以更高的目標(biāo)來(lái)要求自己,在不斷完善自身管理模式和提高技術(shù)研發(fā)能力的同時(shí)，大力倡導(dǎo)推行新經(jīng)濟(jì)品牌戰(zhàn)略，促進(jìn)互聯(lián)網(wǎng)事業(yè)的發(fā)展。
示例代碼如下
package flink.streaming
import org.apache.flink.streaming.api.scala._
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer
import org.apache.flink.api.common.serialization.SimpleStringSchema
object StreamingtoKafkasink {
def main(args: Array[String]): Unit = {
val env = StreamExecutionEnvironment.getExecutionEnvironment
val set = env.readTextFile("d://person")
val producer = new FlinkKafkaProducer[String]("bigdata00:9092,bigdata00:9092","test1",new SimpleStringSchema)
set.addSink(producer)
env.execute("kafkasink")
}
}感謝各位的閱讀！關(guān)于“flink connector之FlinkKafkaProducer的示例代碼”這篇文章就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，讓大家可以學(xué)到更多知識(shí)，如果覺(jué)得文章不錯(cuò)，可以把它分享出去讓更多的人看到吧！
本文標(biāo)題：flinkconnector之FlinkKafkaProducer的示例代碼
文章源于：http://fisionsoft.com.cn/article/pjdggh.html
