Suchergebnisse für Anfrage "apache-kafka"
Wie verwende ich die Android App als „Producing Client“ für Kafka?
Ist es möglich / ist es sinnvoll, eine Android-App als "Producing Client" für Apache Kafka zu verwenden? Angenommen, meine Android-App muss Reaktionszeitdaten erfassen und analysieren. Ziel ist es, alle Daten zu sammeln und die ...
Kafka Streaming Concurrency?
Ich habe einige grundlegende Kafka-Streaming-Codes, mit denen Datensätze aus einem Thema gelesen, verarbeitet und Datensätze zu einem anderen Thema ausgegeben werden. Wie geht Kafka-Streaming mit Parallelität um? Läuft alles in einem Thread? ...
Limit Kafka-Stapelgröße bei Verwendung von Spark Streaming
Ist es möglich, die Größe der vom Kafka-Consumer für Spark Streaming zurückgegebenen Stapel zu begrenzen? Ich frage, weil der erste Stapel, den ich erhalte, Hunderte von Millionen Datensätzen enthält und es Ewigkeiten dauert, sie zu verarbeiten ...
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 Thema pro Produzent
Sagen wir, ich habe mehrere Geräte. Jedes Gerät verfügt über unterschiedliche Sensortypen. Jetzt möchte ich die Daten von jedem Gerät für jeden Sensor an kafka senden. Aber ich bin verwirrt über die Kafka-Themen. Zur Verarbeitung dieser ...
Differenz zwischen session.timeout.ms und max.poll.interval.ms für Kafka 0.10.0.0 und spätere Versionen
Ich bin unklar, warum wir beide brauchensession.timeout.ms undmax.poll.interval.ms und wann würden wir den einen oder anderen oder beide verwenden? Anscheinend geben beide an, dass die obere Grenze des Zeitkoordinators auf den Herzschlag des ...
KafkaAvroDeserializer gibt SpecificRecord nicht zurück, sondern GenericRecord
MyKafkaProducer kann @ verwendKafkaAvroSerializer, um Objekte zu meinem Thema zu serialisieren. Jedoch,KafkaConsumer.poll() kehrt deserialisiert zurückGenericRecord anstelle meiner serialisierten Klasse. ...
Kafka Bestellung mehrerer Partitionen
Mir ist bekannt, dass es nicht möglich ist, mehrere Partitionen in Kafka zu bestellen, und dass die Partitionsreihenfolge nur für einen einzelnen Consumer innerhalb einer Gruppe (für eine einzelne Partition) garantiert ist. Aber ist es jetzt mit ...
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 ...
Kafka - Probleme mit TimestampExtractor
Ich benutzeorg.apache.kafka:kafka-streams:0.10.0.1 Ich versuche, mit einem zeitreihenbasierten Stream zu arbeiten, der anscheinend kein @ auslösKStream.Process() auslösen ("punctuate"). ...