apache-kafka

Fragen
Apache Kafka ist eine verteilte Streaming-Plattform zur Speicherung und Verarbeitung von Datenströmen mit hohem Durchsatz.
1
Antwort

Senden Sie KafkaProducer vom lokalen Rechner an die hortonworks-Sandbox in der virtualbox

Ich habe einen wirklich einfachen Produzenten, den ich auf meinem lokalen Windows-Rechner durch eclipse laufe ... Was ich wirklich will, ist, eine Nachricht an kafka weiterzuleiten, damit ich den Broker durch den Tierpfleger anzeigen kann. Nur u...
17.07.2015, 13:13
2
Antworten

Fehler beim Schreiben von Versatzdaten in kafka-storm

Ich habe einen Sturmcluster eingerichtet, um Echtzeittrending und andere Statistiken zu berechnen, allerdings habe ich einige Probleme, die "Wiederherstellungs" -Funktion in dieses Projekt einzuführen, indem ich den Offset erlaubte, der zuletzt...
25.06.2014, 11:58
3
Antworten

wie man Kafka 0.8 Log4j Appender benutzt

Ich versuche Kafka-0.8 Log4j Appender zu benutzen und kann es nicht machen. Ich möchte, dass meine Anwendung über log4j appender direkt an kafka sendet. Hier ist meine log4j.properties. Ich konnte keinen geeigneten Encoder finden, daher konfi...
26.02.2014, 07:42
1
Antwort

Fehler UNKNOWN_MEMBER_ID ist beim Vergeben von Offsets für die Gruppe xxx aufgetreten

Mit der Java-Bibliothek des Kafka-Clients hat die Verwendung von Protokollen eine Zeit lang funktioniert, aber mit den folgenden Fehlern funktioniert sie nicht mehr: %Vor% Es wird zurückgesetzt. Beim Ausführen einer anderen Instanz dersel...
15.07.2016, 11:09
2
Antworten

Kafka löst java.nio.channels.ClosedChannelException aus

Wenn ich versuche, Nachrichten vom kafka-Server, der in ec2 gehostet wird, mit dem kafka console tool zu konsumieren (V 0.9.0.1, glaube ich, dass dies alte Consumer-APIs verwendet) Ich bekomme folgende Ausnahme. Wie kann ich das überwinden?...
06.04.2016, 04:58
4
Antworten

Maximale Anzahl von Tupelwiederholungen auf Storm Kafka Tülle

Wir benutzen Storm mit der Kafka-Tülle. Wenn wir Nachrichten auslassen, möchten wir sie wiederholen, aber in einigen Fällen führen schlechte Daten oder Codefehler dazu, dass Nachrichten immer einen Bolt auslassen, so dass wir in einen unendliche...
02.10.2015, 16:49
3
Antworten

Wie erreiche ich Multi-Tenancy im Kontext von Kafka und Sturm?

Was sind die besten Praktiken für den Aufbau einer Multi-Tenant-App im Kontext von Kafka und Storm? Beispiel: Erstellen eines Themas für jeden Mandanten und Verwenden von Multi-Themen-Ausläufen (mithilfe von Platzhaltern).     
07.05.2014, 11:21
2
Antworten

Kafka und Firewall-Regeln

Wir haben eine ziemlich strenge Netzwerksegmentierungspolitik. Ich verwende eine Cloud Foundry-Instanz, um eine App zu implementieren. Die Firewall-Regeln wurden so eingerichtet, dass sie den Kafka-Cluster innerhalb der Cloud-Foundry-Instanz err...
22.07.2016, 16:11
1
Antwort

Dynamische Verbindung eines Kafka-Eingabestreams mit mehreren Ausgabeströmen

Ist in Kafka Streams eine Funktion integriert, die es ermöglicht, einen einzelnen Eingabestream dynamisch in mehrere Ausgabeströme zu integrieren? KStream.branch erlaubt Verzweigungen basierend auf echten / falschen Prädikaten, aber das ist...
22.01.2017, 21:11
1
Antwort

Unterschied zwischen Apache Samza und Apache Kafka Streams (Schwerpunkt auf Parallelität und Kommunikation)

In Samza und Kafka Streams wird die Datenstromverarbeitung in einer Sequenz / Grafik (in Samza "Datenflussgraph" und in Kafka Streams "Topologie" genannt) von Verarbeitungsschritten (in Samza "und" Prozessor "genannt) ausgeführt. in Kafka-Bächen...
09.12.2016, 15:46