apache-kafka

7Hitze

2Antwort

Ich googelte und las die Kafka-Dokumentation, aber ich konnte den maximalen Wert eines Consumer-Offsets nicht herausfinden und ob es einen Offset-Wraparound nach dem Maximalwert gibt. Ich verstehe Off

9Hitze

1Antwort

Wie startet man Kafka beim Systemstart in Ubuntu 14.04 automatisch?

Hat Kafka einen offiziellen Weg (z. B. ein init.d-Skript), um Kafka beim Systemstart zu starten? Die einzige offizielle Methode Kafka zu beginnen Ich habe gesehen ist: nohup ~/kafka/bin/kafka-server-s

6Hitze

1Antwort

Konvertieren von pojos in generische Datensätze in confluent.io zum Senden über einen KafkaProducer

Ich bin komplett neu bei Kafka und avro und versuche, das konfluente Paket zu verwenden. Wir haben bestehende POJOs, die wir für JPA verwenden, und ich möchte einfach eine Instanz meiner POJOs erstell

8Hitze

1Antwort

Kafka Consumer "konnte Leiter nicht finden" beim Abrufen von Thema Metadaten

Wenn ich versuche, das Kafka Producer und Consumer (0.9.0) Skript zu verwenden, um Nachrichten von einem Thema zu pushen/ziehen, erhalte ich die folgenden Fehler. Producer Fehler [2016-01-13 02:49:40,

20Hitze

5Antwort

Wann löst der Apache Kafka-Client eine "Batch Expired" -Ausnahme aus?

Mit dem Apache Kafka Java-Client (0.9) versuche ich, eine lange Reihe von Datensätzen an den Broker unter Verwendung der Kafka Producer class zu senden. Der asynchrone send method kehrt sofort für ein

13Hitze

7Antwort

Consumer keine Nachrichten, Kafka-Konsole, neue Consumer-API, Kafka 0,9

Ich mache die Kafka Quickstart für Kafka 0.9.0.0. Ich habe zookeeper bei localhost:2181 hören, weil ich lief bin/zookeeper-server-start.sh config/zookeeper.properties Ich habe einen einzigen Broker

5Hitze

3Antwort

Spark Streaming von Kafka hat Fehler numRecords darf nicht negativ sein

Seine Art von seltsamen Fehler, weil ich noch Daten auf Kafka und Nachricht von Kafka und Nachricht ist auch seltsam. Ich suche und bekomme keine Ressourcen bezogen auf. Lassen Sie mich meinen Cluster

5Hitze

2Antwort

Spark Streaming Kafka Stream

Ich habe einige Probleme beim Lesen von Kafka mit Spark-Streaming. Mein Code ist: val sparkConf = new SparkConf().setMaster("local[2]").setAppName("KafkaIngestor") val ssc = new StreamingContext(spar

8Hitze

1Antwort

Apache Kafka: Metadaten können nicht aktualisiert werden/java.nio.channels.ClosedChannelException

Ich fange gerade erst an 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

7Hitze

1Antwort

Kafka 0.9 - So erstellen Sie ein Thema durch Java-API

Neu bei Kafka. Eine schwierige Zeit herauszufinden, wie man die Java-API verwendet, um ein Thema in der Version 0.9 zu erstellen. Diese answer behandelt 0,8. Ich sehe, dass die Cluster Methoden zum Ab