Questions et réponses pour le spark-streaming-kafka :
Intégration Spark Streaming pour Kafka.
L'approche Direct Stream fournit un parallélisme simple, une correspondance 1: 1 entre les partitions Kafka et les partitions Spark, et l'accès aux décalages et aux métadonnées.
J'essaie d'écrire un dataframe dans kafka au format JSON et d'ajouter une clé au data frame dans Scala, je travaille actuellement avec cet exemple de kafka-spark: df.selectExpr( ...
Je recherche la solution pour ajouter la valeur d'horodatage de kafka à mon schéma de streaming structuré Spark. J'ai extrait le champ de valeur de kafka et j'ai cré&ea ...
