Suchergebnisse für Anfrage "apache-kafka"
Zookeeper mit KeeperException, aber Kafka kann Themen erstellen und produzieren / konsumieren
Ich habe Kafka kürzlich auf einem einzelnen Knoten eingerichtet, um CDH 5 auf einem einzelnen Knoten zu spielen, bevor ich zu einem echten Cluster übergehe. Anfangs habe ich gerade den Zookeeper-Server mit dem Kafka-Server gestartet und alles war ...
Kafka QuickStart, advertised.host.name gibt kafka.common.LeaderNotAvailableException @ a
Ich kann einen einfachen Einknoten-Kafka (kafka_2.11-0.8.2.1) lokal auf einem Linux-Computer ausführen, aber wenn ich versuche, einen Produzenten remote auszuführen, erhalte ich einige verwirrende Fehler. Ich folge der Kurzanleitung ...
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 verwende ich mehrere Verbraucher in Kafka?
Ich bin ein neuer Student, der Kafka studiert, und bin auf einige grundlegende Probleme gestoßen, wenn ich mehrere Verbraucher verstehe, bei denen Artikel, Dokumentationen usw. bisher nicht allzu hilfreich waren. Eine Sache, die ich versucht ...
Welcher Befehl zeigt alle Themen und Offsets von Partitionen in Kafka an?
Ich suche einen Kafka-Befehl, der alle Themen und Offsets von Partitionen anzeigt. Wenn es dynamisch ist, wäre es perfekt. Im Moment verwende ich Java-Code, um diese Informationen anzuzeigen, aber es ist sehr unpraktisch.
kafka-Überwachung mit JMX beim Ausführen von kafka in docker in boot2docker
Ich versuche, die JMX-Überwachung zum Überwachen einer Test-Kafka-Instanz zu aktivieren. Ich habe kafka (ches / kafka) im Docker über boot2docker ausgeführt, kann die JMX-Überwachung jedoch nicht ordnungsgemäß konfigurieren. Ich habe ...
java.lang.ClassNotFoundException: kafka.api.OffsetRequest
Ich erhalte die Fehlermeldung "java.lang.ClassNotFoundException kafka.api.OffsetRequest", während ich versuche, Kafka in unsere Storm-Topologie zu integrieren. Welche Versionen laufen und es funktioniert? Meine pom.xml <dependency> ...
Wie kann man Kafka Broker mit jmxtrans überwachen?
Kafka 0.8.1.1 (kafka_2.8.0-0.8.1.1.tgz) Ich verwende jmxtrans, um eine JMX-Überwachung einer Kafka-Instanz (die im Docker ausgeführt wird) durchzuführen. Leider werden keine Kafka-Messdaten zurückgegeben. Ich habe ein paar Dinge ausprobiert, ...
Wie verwende ich Flinks KafkaSource in Scala?
Ich versuche, ein einfaches Testprogramm mit Flinks KafkaSource auszuführen. Ich benutze folgendes: Flink 0.9Scala 2.10.4Kafka 0.8.2.1Ich habe die Dokumentation befolgt, um KafkaSource zu testen (hinzugefügte Abhängigkeit, Bündelung des ...
Wie wird die Ausgabe von zwei verschiedenen Ausläufen an denselben Bolzen gesendet?
Ich habe zwei Kafka-Ausläufe, deren Werte ich an denselben Bolzen senden möchte. Ist es möglich