kafka-python

0Hitze

2Antwort

AssertionError: Nicht zugeordnete Partition

Im Versuch, Daten von einem Thema zu verbrauchen durch die Offset-Einstellung aber Assertionsfehler erhalten - from kafka import KafkaConsumer consumer = KafkaConsumer('foobar1', bootstrap

10Hitze

4Antwort

Wie wird man spätestens nach einem kafka Thema für eine Partition Offset?

ich die Python hohe Verbraucher für Kafka bin mit und wollen für jede Partition eines Themas die neuesten Offsets kennen. Aber ich kann es nicht zur Arbeit bringen. from kafka import TopicPartition f

4Hitze

3Antwort

kafka-python - Wie stelle ich eine Partition fest?

Verwenden von kafka-python-1.0.2. Wenn ich ein Thema mit 10 Partitionen habe, wie gehe ich über eine bestimmte Partition, während ich die verschiedenen Partitionen und Nachrichten durchlaufe. Ich kann

26Hitze

4Antwort

Kafka in Docker funktioniert nicht

Ich versuche wurstmeister\kafka-docker Bild mit docker-compose zu verwenden, aber ich habe echte Probleme mit der Verbindung alles. Alle Beiträge oder Fragen, die ich überprüfe, scheint keine Probleme

6Hitze

1Antwort

Senden von großen CSV an Kafka mit Python Spark

Ich versuche, eine große CSV an Kafka zu senden. Die Grundstruktur besteht darin, eine Zeile der CSV-Datei zu lesen und sie mit der Kopfzeile zu komprimieren. a = dict(zip(header, line.split(",") Di