J'essaye d'envoyer un grand CSV à kafka. La structure de base est de lire une ligne du fichier CSV et de la compresser avec l'en-tête. a = dict(zip(header, line.split(",")
Cela devient ensuite conve
je rembobinées fetch de décalage pour un consommateur Kafka dans le groupe G1 à ARRET1 par le code suivant: consumer1.set_topic_partitions((topic, partition, off1))
Dans la ligne ci-dessus, ARRET1 e