064 SparkStream与kafka的集成

标签：集成   ons   mil   使用   apach   nbsp   内部使用   apache   api   

一：说明

1.官网

　　指导网址：http://spark.apache.org/docs/1.6.1/streaming-kafka-integration.html

2.SparkStream+kafka

　　Use Receiver

　　　　内部使用kafka的high lenel consumer API

　　　　consumer offset 只能保持到zk/kafka中，只能通过配置进行offset的相关操作

　　Direct

　　　　内部使用的是kafka的simple consumer api

　　　　自定义对kafka的offset偏移量进行控制操作

　　　　集成依赖pom配置：

二：

064 SparkStream与kafka的集成

标签：集成   ons   mil   使用   apach   nbsp   内部使用   apache   api   

原文地址：https://www.cnblogs.com/juncaoit/p/9452333.html