Sto provando a inviare un grande CSV a kafka. La struttura di base è leggere una riga del CSV e comprimerla con l'intestazione. a = dict(zip(header, line.split(",")
questo viene poi convertito in un
Sto usando il consumer di alto livello Python per Kafka e voglio sapere gli ultimi offset per ogni partizione di un argomento. Tuttavia non riesco a farlo funzionare. from kafka import TopicPartition
Sto cercando di utilizzare l'immagine wurstmeister\kafka-docker con docker-compose, ma sto avendo problemi reali con il collegamento di tutto. Tutti i post o le domande che controllo, sembra non avere