J'ai un sujet Kafka avec 3 partitions et je consomme ces données en utilisant le streaming structuré Spark. J'ai 3 consommateurs (disons le groupe de consommateurs A) lisant c ...
Mon travail de streaming structuré Spark génère en continu des fichiers parquet que je souhaite supprimer après l'expiration (disons après 30 jours). Je stoc ...
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 ...
