apache-kafka

31Hitze

1Antwort

So löschen Sie ein Thema in Apache kafka

Ich muss ein Thema in kafka-0.8.2.2.3 löschen. bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic DummyTopic Der Befehl wird erfolgreich ausgeführt, aber wenn ich einen Befehl ausführen

17Hitze

2Antwort

Ist es möglich, Partitionen zu einem bestehenden Thema in Kafka hinzuzufügen 0.8.2

Ich habe einen Kafka-Cluster mit 2 Partitionen. Ich suchte nach einer Möglichkeit, die Anzahl der Partitionen auf 3 zu erhöhen. Ich möchte jedoch keine vorhandenen Nachrichten im Thema verlieren. Ich

9Hitze

2Antwort

Wie kann ich ein Mock Kafka Topic für Junit-Tests instanziieren?

Ich habe einige JUnit-Tests für Code, der ein Kafka-Thema verwendet. Die gespielten Kafka-Themen, die ich ausprobiert habe, funktionieren nicht und die online gefundenen Beispiele sind sehr alt, daher

8Hitze

5Antwort

Ist kafka consumer 0.9 abwärtskompatibel?

Wird der kommende kafka consumer 0.9.x mit 0.8 broker kompatibel sein? Mit anderen Worten - es ist möglich, nur auf neue Verbraucher-Implementierung zu wechseln, ohne etwas anderes zu berühren?

5Hitze

1Antwort

Kafka-Schema Registrierungsfehler: Fehler beim Schreiben von Noop-Datensatz in Kafka-Filiale

Ich versuche, die Kafka-Schemaregistrierung zu starten, bekomme aber folgenden Fehler: Fehler beim Schreiben von Noop-Datensatz in Kafka-Speicher. Stack-Trace ist unten. Ich überprüfte die Verbindunge

5Hitze

2Antwort

Wie lade ich ein Kafka-Thema in HDFS?

Ich verwende hortonworks Sandbox. Schaffung Thema: ./kafka-topics.sh --create --zookeeper 10.25.3.207:2181 --replication-factor 1 --partitions 1 --topic lognew holend das Apache-Zugriffsprotokoll Ve

12Hitze

3Antwort

Kafka 0.8.2.1 Wie liest man aus __consumer_offsets topic

Ich versuche herauszufinden, welche Offsets meine aktuellen High-Level-Verbraucher abarbeiten. Ich benutze Kafka 0.8.2.1, mit nein "offset.storage" in den server.properties von Kafka - was meiner Mein

6Hitze

1Antwort

Kafka Verbraucher erhalten keine Nachrichten, bis neu gestartet

habe ich versucht, sowohl Kafka 0.8.2.2 und 0.9.0.0 und bin das gleiche Problem auf beiden zu sehen, was das ist: ich einen frischen Zookeeper und Kafka-Server starten (leere Daten/Log-Verzeichnisse),

8Hitze

6Antwort

Fehler beim Veröffentlichen der Nachricht zu Kafka Thema

Ich bin neu in Kafka und versuche, Umgebung dafür einzurichten. Ich versuche, einen einzelnen Knoten Kafka auszuführen, aber ich bekomme Fehler darin. Nach folgenden Schritte auf mac 1. brew install z

7Hitze

2Antwort

Wie erstellt man InputDStream mit Offsets in PySpark (mit KafkaUtils.createDirectStream)?

Wie zu verwenden KafkaUtils.createDirectStream mit den Offsets für eine bestimmte in Pyspark?