Suchergebnisse für Anfrage "apache-kafka"
Kafka-Thema existiert nach Neustart nicht mehr
Ich habe ein Thema in meinem lokalen Kafka-Cluster mit 3 Servern / Brokern erstellt, indem ich in meinem Kafka-Installationsverzeichnis Folgendes ausgeführt habe: bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor ...
Spark: Mehrere Kafka-Themen gleichzeitig bearbeiten
Ich benutzespark 1.5.2. Ich muss den Spark-Streaming-Job mit Kafka als Streaming-Quelle ausführen. Ich muss aus mehreren Themen in kafka lesen und jedes Thema anders verarbeiten. Ist es eine gute Idee, dies im selben Job zu tun? Wenn ja, sollte ...
Kafka Consumer Offset Maximalwert?
Ich habe Kafka-Dokumentation gegoogelt und gelesen, aber ich konnte den Maximalwert eines Consumer-Offsets nicht herausfinden und ob es einen Offset-Wraparound nach dem Maximalwert gibt. Ich verstehe, Offset ist ein Int64-Wert, also ist der ...
Wie werden verteilte Kafka-Broker, -Produzenten und -Konsumenten in einem lokalen Netzwerk eingerichtet / verbunden?
ch habe Apache Kafka eingerichtet und bestätigt, dass Produzenten und Konsumenten auf dem localhost arbeite Wie richte ich Kafka so ein, dass: mehrere Produzenten senden Nachrichten an einen Broker auf einem NetzwerkcomputerViele Konsumenten im ...
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.
kann keine Verbindung zum kafka-Server herstellen
Ich versuche, Kafka mit Version 0.9.0 mit Port 9092 zu verwenden. Wenn ich Telnet verwende, stelle ich eine Verbindung zu dieser Adresse her, kann jedoch mit der Java-API keine Verbindung zum Kafka-Server herstellen. Hier ist mein Java-Beispiel ...
Wie werden Daten von Kafka an Spark Streaming übergeben?
Ich versuche, Daten von Kafka an Spark-Streaming zu übergeben. Das habe ich bis jetzt gemacht: Installed bothkafka undsparkGestartetzookeeper mit Standardeigenschaften configGestartetkafka server mit Standardeigenschaften ...
Wann löst der Apache Kafka-Client eine "Batch Expired" -Ausnahme aus?
Mit dem Apache Kafka Java-Client (0.9) versuche ich, eine lange Reihe von Datensätzen mit dem @ -Zeichen an den Broker zu sendeKafka ...
Karaf - Kafka OSGI-Bundle - Herstellerausgabe
Ich versuche ein einfaches Bundle für Kafka Producer in Apache Karaf Version 4.0.3 zu erstellen. Hier ist mein Java-Code Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("acks", "all"); ...
Verbindung zwischen Apache Kafka und JMS
Ich habe mich gefragt, ob Apache Kafka kommunizieren und Nachrichten an JMS senden kann. Kann ich eine Verbindung zwischen ihnen herstellen? Zum Beispiel verwende ich JMS in meinem System und es sollte Nachrichten an das andere System senden, das ...