Suchergebnisse für Anfrage "apache-kafka"
So finden Sie die kafka-Version unter Linux
Wie finde ich die Kafka-Version unter Linux? ob es eine möglichkeit gibt, die installierte kafka-version zu finden, außer die version beim herunterladen zu erwähnen?
KafkaUtils Klasse nicht im Spark Streaming gefunden
Ich habe gerade mit Spark Streaming begonnen und versuche, eine Beispielanwendung zu erstellen, die Wörter aus einem Kafka-Stream zählt. Obwohl es mit @ kompiliesbt package, wenn ich es starte, bekomme ichNoClassDefFoundError. ...
Wie stelle ich die Java-Optionen für Kafka ein?
Ich habe mit Kafka experimentiert und anhand der Dokumentation auf der Hauptseite festgestellt, dass Sie verschiedene Optionen für die JVM festlegen können, z. B. die Größe des Heapspeichers und den verwendeten Garbage Collector: http: ...
Spark streaming StreamingContext.start () - Fehler beim Starten von Empfänger 0
Ich habe ein Projekt, das Spark-Streaming verwendet, und ich starte es mit 'spark-submit', aber ich treffe diesen Fehler: 15/01/14 10:34:18 ERROR ReceiverTracker: Deregistered receiver for stream 0: Error starting receiver 0 - ...
Consuming von Kafka fehlgeschlagen Iterator ist im Status fehlgeschlagen
Ich erhalte eine Ausnahme, während ich die Nachrichten von kafka konsumiere. org.springframework.messaging.MessagingException: Consuming from Kafka failed; nested exception is ...
Slow Consumer Throuput bei Verwendung von 2 Consumer-Konfigurationen
Mit der Erweiterung spring-integration-kafka und der folgenden Konfiguration: <int-kafka:zookeeper-connect id="zookeeperConnect" zk-connect="#{kafkaConfig['zooKeeperUrl']}" zk-connection-timeout="10000" zk-session-timeout="10000" ...
Kafka Producer - Unterstützt standardmäßig Multithreading?
Ich bin Neuling bei kafka. Ich habe mit kafka_2.9.2-0.8.1.1 Beispielprogramme für die Synchronisierung von Produzenten und Verbrauchergruppen erstellt. Meine Frage ist also, muss ich dem Produzenten Multithreading-Code hinzufügen (wie es die ...
Java, Wie bekomme ich die Anzahl der Nachrichten in einem Thema in Apache Kafka?
Ich benutze Apache Kafka für Messaging. Ich habe den Producer und Consumer in Java implementiert. Wie kann die Anzahl der Nachrichten in einem Thema ermittelt werden?
Kafka Consumer Rebalancing-Algorithmus
Kann mir jemand sagen, was der Algorithmus für die Neuverteilung für Kafka-Verbraucher ist? Ich würde gerne verstehen, wie sich die Anzahl der Partitionen und die Consumer-Threads darauf auswirken. Vielen Dank
Echtzeit-Protokollverarbeitung mit Apache Spark Streaming
Ich möchte ein System erstellen, in dem ich Protokolle in Echtzeit lesen und mit Apache Spark verarbeiten kann. Ich bin verwirrt, ob ich etwas wie Kafka oder Gerinne verwenden soll, um die Protokolle an Spark Stream weiterzuleiten, oder ob ich ...