欢迎光临回收数控机床随叫随到,正规渠道,欢迎咨询!

高价回收数控机床,拥有多年经验,经济实力强!

回收数控机床

0x02 Scala Kafka生产者示例代码

作者:安尼      发布时间:2021-04-17      浏览量:0
使用Scala编写的Producer样例

使用Scala编写的Producer样例代码
gitHub:https://github.com/duchaoqun/aoye

包info.aoye.kafkaimport java.util.Propertiesimport org.apache.kafka.clients.producer.{KafkaProducer,ProducerConfig,ProducerRecord,记录元数据}/*测试学习生产者*@Author duchaoqun*/ObjectTestProducer扩展了Scala.App{//创建Producer配置文件对象Val props=新的属性()pros.put(“bootstrap.server”,“node 1:6667”)pros.put(“ack”,“all”)pros.put(“retry”,“0”)pros.put(“batch.size”,“16384”)pros.put(“linger.ms”,“1”)pros.put(“Buffer.Memory”,“33554432”)pros.put(“key.序列化程序”,“org.apache.kafka.common.serialization.StringSerializer”)pros.put(“value e.序列化程序”),“org.apache.kafka.Common.序列化”。//创建一个Producer Val Producer=newKafkaProducer[String,String](Props)//发送数据for(i<;-1至100){Producer.send(新ProducerRecord[String,String](“My-Topic”,i.toString,i.toString)}//关闭Producer,释放资源Producer.Close(})。
在线客服 在线客服 QQ咨询
返回顶部 返回顶部 返回顶部