kafka-consumer-api

2Hitze

1Antwort

Fehler beim Lesen Feld "Themen": java.nio.BufferUnderflowException in Kafka

9.0 Client, um Nachrichten von zwei Brokern, die auf einem Remote-System laufen zu konsumieren.Mein Producer funktioniert gut und ist in der Lage, Nachrichten an den Broker, aber meine Verbraucher zu

5Hitze

1Antwort

Ist es möglich, in Kafka + SparkStreaming einen spezifischen Nachrichten-Offset zu erhalten?

Ich versuche, den Offset für eine bestimmte Nachricht in Kafka mithilfe von Spark Direct Stream zu erhalten und zu speichern. Mit Blick auf die Spark-Dokumentation erhalten Sie einfach die Bereichsoff

0Hitze

2Antwort

Kafka Topic Partition

Kafka Topic Partition Offset-Position immer von 0 oder Zufallswert und Wie sicher der Consumer-Datensatz ist der erste Datensatz in der Partition? Gibt es einen Weg, das herauszufinden? Bitte lass es

8Hitze

3Antwort

Kafka Java SimpleConsumer seltsame Codierung

Ich versuche, die SimpleConsumer in Kafka 9 zu verwenden, um Benutzer zu ermöglichen, versetzt von einer Zeit, Ereignisse zu wiederholen - aber die Nachrichten ich von Kafka sind in einer sehr seltsam

5Hitze

1Antwort

Kafka Consumer Poll() -Methode wird blockiert

Ich bin neu in Kafka 0.9 und testen einige Funktionen, die ich ein seltsames Verhalten in der Java-implementiert Consumer (KafkaConsumer) realisiert. Der Kafka-Broker befindet sich in einem externen G

1Hitze

1Antwort

Kafka Consumer WakeupException Handhabung Java

Wenn ich den kafka Verbraucher in einem Thread laufen lasse, ohne ihn von außen zu manipulieren, wie den Verbraucher einzuschalten oder ihn aufzuwecken, ist es notwendig, die WakeupException richtig z

0Hitze

1Antwort

Warum commitAsync die ersten 2 Offsets nicht committen kann

Ich hatte ein seltsames Problem, bei dem der Konsument die ersten 2 Offsets des Logs nicht mit comitAsync machen konnte und ich weiß nicht, warum. Es ist sehr seltsam, weil die anderen Nachrichten in

1Hitze

2Antwort

Kafka.Utils.createRDD Vs KafkaDirectStreaming

Ich würde gerne wissen, wenn die Lesevorgänge aus einer Kafka-Warteschlange schneller ist, indem Sie Batch-Kafka RDD anstelle von KafkaDirectStream verwenden, wenn ich alle Kafka-Warteschlange lesen m

6Hitze

4Antwort

Kafka Consumer - Umfrageverhalten

Ich habe einige ernste Probleme, eine Lösung für meine Bedürfnisse zu implementieren, in Bezug auf KafkaConsumer (> = 0.9). Stellen wir uns vor, ich habe eine Funktion, die nur n Nachrichten von einem

0Hitze

2Antwort

Warum Kafka Consumer-API ist nicht Daten aus mehreren Partitionen eines Themas

Hinweis holen: Mit kafka_2.11-0.9.0.1 Ich habe ein kafka Thema erstellt mit dem Namen: consumer-tutorials mit 3 Partitions wie folgt: C:\kafka_2.11-0.9.0.1>.\bin\windows\kafka-topics.bat --describe --