apache-kafka

3Hitze

3Antwort

Wie Multithread-Verbraucher in Kafka 0.9.0 verwenden?

Die Doc Kafka einen Ansatz gibt etwa mit folgenden beschrieben: Einen Verbraucher pro Thema: Eine einfache Möglichkeit ist, die jeweils ihre eigenen Verbraucher> Instanz geben fädelt. Mein Code: publi

1Hitze

2Antwort

Wie man ein Kafka Broker Start Skript im Hintergrund mit Ansible

Wie ein Kafka Broker starten Skript in ansible im Hintergrund geschrieben ausführen, wenn ich es normalerweise ausführen es im Vordergrund ausgeführt wird und ich bin nicht in der Lage, zurück zu beko

9Hitze

1Antwort

Wie verbessert man die langsame Leistung von reaktiven Kafka (Scala plus Akka Streams)?

Ich bewege mein Projekt von RabbitMQ nach Kafka und versuche zu verstehen, wie schnell reaktives Kafka sein wird. Ich bin derzeit in der Lage, etwa 12K/sec triviale Nachrichten/Sek zu Rabbit zu schrei

0Hitze

1Antwort

org.apache.kafka.common.errors.ApiException: Das Sitzungszeitlimit ist nicht in einem akzeptablen Bereich

Ich bekomme oben Ausnahme in meinem Verbraucher mit Kafka 0.9.0.1. Nach diesem Thread [1] sehe ich nicht die " group.max.session.timeout.ms "-Eigenschaft in der Datei server.properties. org.apache.kaf

2Hitze

1Antwort

Kafka: ein Fehler trat in einem kürzlich unsicheren Speicherzugriffsvorgang in kompiliertem Java-Code auf

Nach der Veröffentlichung einiger Nachrichten an Kafka, bekomme ich unten Fehler. Bitte helfen Sie ein Problem zu debuggen. Und Maschine hat genügend Speicher. [email protected]:/home/kafka/kafka/logs

0Hitze

1Antwort

Lesen gz.parquet Datei

Hallo Ich muss die Daten von gz.parquet Dateien lesen, aber nicht wissen, wie ?? Mit Impala versucht, aber ich bekomme das gleiche Ergebnis wie parquet-tools cat ohne die Tabellenstruktur. S.S .: alle

2Hitze

2Antwort

Installieren Sie Kafka als Windows-Dienst

Wie kann ich Apache Kafka als Windows-Dienst installieren und ausführen? Im Moment muss ich zur Eingabeaufforderung gehen und zoekeeper und kafka server starten. Gibt es eine Möglichkeit, Apache Kafka

0Hitze

2Antwort

kafka-log4j-appender 0.9.0.1 wegwerfbare Informationen für Fehler

Sieht so aus, als ob kafka-log4j-appender 0.9.0.1 wegwerfbare Informationen weglässt, wenn eine Nachricht an Kafka gesendet wird. Ich bin mit folgenden Konfiguration: log4j.rootLogger=INFO, stdout lo

1Hitze

2Antwort

funke kafka integration checkpoint wiederverwenden

Ich benutze Ansatz 2 von http://spark.apache.org/docs/latest/streaming-kafka-integration.html, ich benutze check pointing, und wenn ich Code ändern musste, und meinen Code erneut bereitstellen, manchm

1Hitze

1Antwort

Apache Kafka-Konsole Producer-Consumer Beispiel

Ich habe Apache Kafka auf einem Windows-System installiert und ein Konsolen-Producer-Consumer-Beispiel versucht. Wenn ich dem Thema neue Konsumenten hinzufüge, werden nur die Nachrichten nach dem Hinz