抄别人的都抄不明白
Spark Streaming使用Kafka保证数据零丢失spark streaming从1.2开始提供了数据的零丢失,想享受这个特性,需要满足如下条件:数据输入需要可靠的sources和可靠的receivers应用metadata...
抄别人的都抄不明白
Spark Streaming使用Kafka保证数据零丢失spark streaming从1.2开始提供了数据的零丢失,想享受这个特性,需要满足如下条件:数据输入需要可靠的sources和可靠的receivers应用metadata...
还有你存的时候是kafka_offset:$groupId 取的时候是kafka_offset:groupId,这是一张表吗?能取到数据?
sparkstreaming将offset存到hbase之前一直将offset存到zookeeper,由于streaming程序会对zk有大量的读取操作,故将offset存到zk不太好,现已将offset都改到hbase中 kaf...
AnalysisParam这个类是啥
sparkstreaming将offset存到hbase之前一直将offset存到zookeeper,由于streaming程序会对zk有大量的读取操作,故将offset存到zk不太好,现已将offset都改到hbase中 kaf...