为什么不推荐在kafka-consumer中使用zookeeper以及为什么建议使用bootstrap服务器呢?bootstrap-server的优点是什么?
apache-kafka apache-zookeeper
我从Avaf(序列化器和反序列化器)获得了kafka主题的推文.然后我创建了一个Spark消费者,它在RDD [GenericRecord]的Dstream中提取推文.现在我想将每个rdd转换为数据帧,以通过SQL分析这些推文.有什么解决方案可以将RDD [GenericRecord]转换为数据帧吗?
scala avro apache-spark spark-dataframe
apache-kafka ×1
apache-spark ×1
apache-zookeeper ×1
avro ×1
scala ×1
spark-dataframe ×1