Demand Kafka + SparkStreaming + HBase
CodePudding user response:
Sparkstreaming - kakfa under the jars, and then the good related HBase jar packageDevelopment of kafka can use KafkaUtils createDirectStream and createStream class loading data flow
And then through the data stream foreachRDD RDD, use of RDD mapPartitions class to kafka data to HBase, note mapPartitions need to collect will truly implemented