Suchergebnisse für Anfrage "kafka-consumer-api"
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?
Ist kafka consumer 0.9 abwärtskompatibel?
Ist der kommende kafka consumer 0.9.x mit dem 0.8 Broker kompatibel? it anderen Worten: Es ist möglich, nur auf eine neue Consumer-Implementierung zu wechseln, ohne etwas anderes zu berühre
Kafka-Consumer-Konfiguration / Leistungsprobleme
Ich probiere kafka als Alternative zu AWS SQS aus. Die Motivation ist in erster Linie, die Leistung dort zu verbessern, wo kafka die Einschränkung eliminieren würde, 10 Nachrichten gleichzeitig mit einer Obergrenze von 256 KB zu empfangen. Hier ...
Kafka wie man von __consumer_offsets topic @ lie
Ich versuche herauszufinden, welche Offsets meine aktuellen High-Level-Konsumenten abarbeiten. Ich benutze Kafka 0.8.2.1, mitNei "offset.storage" in den server.properties von Kafka eingestellt - was meiner Meinung nach bedeutet, dass Offsets in ...
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 ...
Wie man den Gruppennamen festlegt, wenn man Nachrichten in kafka über die Kommandozeile konsumiert
Eine Idee, wie Sie den Gruppennamen festlegen, wenn Sie Nachrichten in kafka über die Befehlszeile empfangen. Ich habe es mit dem folgenden Befehl versucht: bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic ...
Kafka consumer - In welchem Verhältnis stehen Consumer-Prozesse und -Threads zu Topic-Partitionen?
Ich habe in letzter Zeit mit Kafka zusammengearbeitet und bin hinsichtlich der Verbraucher in einer Verbrauchergruppe ein bisschen verwirrt. Das Zentrum der Verwirrung ist, ob Verbraucher als Prozesse oder Threads implementiert werden sollen. Bei ...
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 ...
Ein und dieselbe Nachricht mehrmals von Kafka lesen
Ich benutzeSpring Kafka API [http://docs.spring.io/spring-kafka/reference/htmlsingle/#_retrying_deliverieshttp://] um Kafka Consumer mit manueller Offsetverwaltung zu implementieren: @KafkaListener(topics = "some_topic") public void ...
NoBrokersAvailable: NoBrokersAvailable-Kafka Error
ch habe bereits angefangen, Kafka zu lernen. Probieren Sie grundlegende Operationen aus. Ich habe an einem Punkt festgehalten, der sich mit den "Brokern" befasst. Meine Kafka läuft, aber wenn ich eine Partition erstellen möchte. from kafka ...