Suchergebnisse für Anfrage "apache-kafka"
Print Kafka Stream Input out to console?
Ich habe in der Kafka-Dokumentation nach einer Java-Anwendung gesucht, an der ich gerade arbeite. Ich habe versucht, mich mit der in Java 8 eingeführten Lambda-Syntax vertraut zu machen, bin aber in diesem Punkt etwas skizzenhaft und bin mir ...
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. ...
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"). ...
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 ...
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 ...
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 ...
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 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? ...
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 ...