【文件属性】：
文件名称：kafka-exactly-once
文件大小：2.05MB
文件格式：ZIP
更新时间：2021-05-13 08:33:00
Scala
卡夫卡一次
我为Spark贡献的Kafka createDirectStream / createRDD api的用法示例（自Spark 1.3起可用）
大师对应于Spark 2.0 / Kafka 0.10
如果您正在寻找较早的版本，请参见
有关更多详细信息，请参见或或或
如果您想尝试运行此程序，
schema.sql包含所用表的postgres模式
src / main / resources / application.conf包含jdbc和kafka配置信息
尽管IdempotentExample假定每个消息正文都是唯一的，但示例与所使用的确切kafka主题或消息格式无关。
【文件预览】：
kafka-exactly-once-master
----schema.sql(814B)
----index.html(8KB)
----src()
--------main()
----build.sbt(1KB)
----.gitignore(756B)
----blogpost.md(25KB)
----project()
--------plugins.sbt(57B)
--------build.properties(19B)
----README.md(959B)
----SS-SF-2015-Koeninger.key(1.85MB)
----slides()
--------remark-latest.min.js(229KB)
--------kixer-logo.png(3KB)
--------spark-kafka-change-cpu-utilization.png(93KB)
--------kafka-new.png(154KB)
--------kafka-old.png(166KB)