Posts tagged with kafka


说明 该文档详细描述使用scala编码word count任务,通过sbt工具构建包,提交spark streaming任务。 实现了几种有代表性的任务.包括从文件系统、HDFS读写,从tcp socket读写, 从kafka读写,实现无状态、有状态、滑动窗口、故障恢复。 测试环境 ssh: root@10.2.35.117 密码 123456 ssh: hadoop@10.2.35.117 密码 123456 spark安装目录 /usr/…