apache-kafka

Ich verwende Kafka 0.8.2.1 und die neue Producer-API. Der Server wird als einzelner Knoten im lokalen Netzwerk eingerichtet. Das Problem ist, dass der Producer eine EOFException nach einer gewissen Zeit (15 Minuten beim letzten Mal) ausgibt,...

Ich versuche, den SimpleConsumer in Kafka 9 zu verwenden, um Benutzern zu erlauben, Ereignisse von einem Zeitversatz wiederzugeben - aber die Nachrichten, die ich von Kafka zurückerhalte, sind in einer sehr merkwürdigen Kodierung: %Vor% Mit...

Ich habe gegoogelt und die Kafka-Dokumentation gelesen, aber ich konnte den Maximalwert eines Verbraucher-Offsets und ob es einen Offset-Wraparound nach dem Maximalwert gibt, nicht herausfinden. Ich verstehe Offset ist ein Int64-Wert, so ist Max...

Projekteinrichtung: 1 Produzent - serialisiert Objekte & amp; sendet Bytes an Kafka 1 Spark Consumer - sollte DefaultDecoder in kafka.serializer verwenden Paket, um Bytes zu verbrauchen Problem: SBT importiert korrekte Bibliothe...