Suchergebnisse für Anfrage "kafka-consumer-api"
Warum ist die Leistung von Kafka-Verbrauchern langsam?
Ich habe ein einfaches Thema und einen einfachen Kafka-Konsumenten und -Produzenten mit der Standardkonfiguration. Das Programm ist sehr einfach, ich habe zwei Threads. Im Producer werden weiterhin 16-Byte-Daten gesendet. Und auf der ...
Wie funktioniert die Neuausrichtung der Verbraucher in Kafka?
Wenn ein neuer Verbraucher / Händler hinzugefügt wird oder ausfällt, löst Kafka einen Ausgleichsvorgang aus. Ist Kafka Rebalancing eine Blockieroperation? Werden Kafka-Verbraucher während eines Ausgleichsvorgangs gesperrt?
Kafka Consumer empfängt keine Nachrichten
Ich bin ein Neuling in Kafka. Ich habe viele Anweisungen im Internet gelesen, um einen Kafka-Produzenten und einen Kafka-Konsumenten zu machen. Ersteres habe ich erfolgreich gemacht, wodurch Nachrichten an Kafka Cluster gesendet werden können. ...
Unterschied zwischen groupid und consumerid in Kafka consumer
Ich bin neu bei Kafka. Mir ist in der Consumer-Konfiguration aufgefallen, dass diese zwei IDs hat. Eine ist group.id (obligatorisch) und die zweite ist consumer.id (nicht obligatorisch). Bitte erklären Sie, warum 2 Ids und Unterschied.
Kafka Avro Consumer mit Decoder-Problemen
Wenn ich versucht habe zu rennenKafka Consumer mit Avro [https://gist.github.com/yaroncon/97082e0b794d83fccf12] Über den Daten mit meinem jeweiligen Schema wird der Fehler "AvroRuntimeException: Fehlerhafte Daten. Länge ist negativ: -40" ...
JBOSS gibt org.apache.kafka.common.KafkaException aus: auth.conf kann nicht gelesen werden
Wenn ich in wildfly v 10 das war meines einfachen kafka-projekts (das gut als jar funktioniert) einsetze, erhalte ich eine ausnahmebedingung für die zookeeper-verbindung [1 [1]] 15:21:58,531 ERROR [org.jboss.msc.service.fail] (ServerService ...
Kafka: Ändere die Anzahl der Partitionen für ein bestimmtes Thema mit java
Ich bin neu bei Kafka und arbeite mit dem neuen KafkaProducer und KafkaConsumer, Version: 0.9.0.1. Ist es in Java möglich, die Anzahl der Partitionen für ein bestimmtes Thema zu ändern / zu aktualisieren, nachdem es erstellt wurde. Ich benutze ...
Kafka 0.9.0.1 Java Consumer bleibt in awaitMetadataUpdate () hängen
Ich versuche, einen einfachen Kafka-Konsumenten mit der Java-API v0.9.0.1 zum Laufen zu bringen. Der von mir verwendete Kafka-Server ist ein Docker-Container, auf dem auch Version 0.9.0.1 ausgeführt wird. Unten ist der Verbrauchercode: public ...
Kafka-Thema in einem Spark-Batch-Job lesen
Ich schreibe einen Spark-Stapeljob (v1.6.0), der aus einem Kafka-Thema liest. Dafür kann ichorg.apache.spark.streaming.kafka.KafkaUtils#createRDD Ich muss jedoch die Offsets für alle Partitionen festlegen und sie auch irgendwo speichern (ZK? ...
Differenz zwischen session.timeout.ms und max.poll.interval.ms für Kafka 0.10.0.0 und spätere Versionen
Ich bin unklar, warum wir beide brauchensession.timeout.ms undmax.poll.interval.ms und wann würden wir den einen oder anderen oder beide verwenden? Anscheinend geben beide an, dass die obere Grenze des Zeitkoordinators auf den Herzschlag des ...