apache-kafka, Seitenzahl 3

2

Antworten

UnknownHostException kafka

Ich versuche einen Kafka-Cluster einzurichten (eigentlich der erste Knoten im Cluster). Ich habe ein Cluster-Setup für einen einzelnen Knoten. Ich richte Kafka auf einem separaten Knoten ein. Beide laufen CentOS 6.4, laufen IPV6, was ein b...

26.08.2014, 02:52

1

Antwort

Was kafka.common.OffsetOutOfRangeException bedeutet

Ich versuche, Daten über Apache Kafka zu laden und bekomme ständig diesen Fehler: kafka.common.OffsetOutOfRangeException: Offset 1003786 liegt außerhalb des Bereichs bei kafka.log.Log $ .findRange (Log.scala: 46) bei ka...

09.04.2014, 08:20

2

Antworten

So sehen Sie die Aufbewahrung für ein bestimmtes Thema in kafka

Ich möchte die Aufbewahrungsfrist für ein bestimmtes Thema sehen. Gibt es einen Befehl? Ich habe versucht mit bin / kafka-topics.sh --zookekeeper hostname : 2181 --alter --config retention.ms = 172800000 --topic zum Löschen von 2 Tage alten Da...

14.12.2016, 05:59

3

Antworten

Der Zookeeper-Server kann nicht gestartet werden - Kafka Setup

Ich versuche, Kafka mit der Schnellstartanleitung auf der Apache Kafka-Seite einzurichten, und beim Starten des Zooheeper-Servers bleibt er bei diesem Schritt hängen ... Würde mich freuen, wenn mir jemand helfen könnte, den Tierpfleger zu starte...

26.05.2015, 22:52

3

Antworten

Kafka 0.9 Wie man eine Nachricht wieder aufnimmt, wenn man den Offset mit einem Kafka Consumer manuell festlegt

Ich schreibe einen Verbraucher, der den Offset manuell festlegt, sobald eine Reihe von Aufzeichnungen an Mongo übergeben wurde. Im Falle eines Mongo-Fehlers oder eines anderen Fehlers wird versucht, den Datensatz in eine Fehlerbehandlungssammlu...

20.01.2016, 13:46

6

Antworten

Fehler beim Veröffentlichen der Nachricht zum Kafka-Thema

Ich bin neu bei Kafka und versuche, dafür eine Umgebung einzurichten. Ich versuche, einen einzelnen Knoten Kafka zu betreiben, aber ich bekomme Fehler darin. Folge den Schritten auf dem Mac %Vor% Aber ich bekomme folgenden Fehler. Bitte l...

19.10.2015, 10:24

1

Antwort

Konfigurieren Sie kafka-net so, dass keine neuen Nachrichten mehr gesendet werden

Ich benutze kafka 0.8.1.1 auf einer Red Hat VM mit kafka-net plugin. Wie kann ich meinen Kunden so konfigurieren, dass er keine früheren Nachrichten von kafka mehr empfängt? Mein Verbrauchercode: %Vor%

13.03.2015, 21:19

1

Antwort

Apache Kafka: Aktualisierung von Metadaten / java.nio.channels.ClosedChannelException fehlgeschlagen

Ich beginne gerade mit Apache Kafka / Zookeeper und habe Probleme beim Einrichten eines Clusters in AWS. Derzeit habe ich drei Server: Ein laufender Zookeeper und zwei laufende Kafka. Ich kann die Kafka Server ohne Probleme starten und kan...

14.12.2015, 02:54

5

Antworten

Spark Streaming + Kafka: SparkException: Es konnten keine Vorlaufoffsets für Set gefunden werden

Ich versuche, Spark Streaming einzurichten, um Nachrichten aus der Kafka-Warteschlange zu erhalten. Ich erhalte den folgenden Fehler: %Vor% Hier ist der Code, den ich ausführe (pyspark): %Vor% Es gab ein paar ähnliche Posts mit demselben...

15.12.2015, 11:48

2

Antworten

Wie behebt man "java.io.NotSerializableException: org.apache.kafka.clients.consumer.ConsumerRecord" in Spark Streaming Kafka Consumer?

Spark 2.0.0 Apache Kafka 0.10.1.0 scala 2.11.8 Wenn ich Spark-Streaming und Kafka-Integration mit Kafka-Broker-Version 0.10.1.0 mit dem folgenden Scala-Code schlägt es mit folgender Ausnahme fehl: %Vor% Warum? Wie man es repariert...

13.11.2016, 05:26