Suchergebnisse für Anfrage "apache-kafka"
Änderung der Aufbewahrungsfrist von Kafka während der Laufzeit
Wie ändere ich mit Kafka 0.8.1.1 die Protokollaufbewahrungszeit, während es ausgeführt wird? DasDokumentatio [http://kafka.apache.org/documentation.html#brokerconfigs] sagt die Eigenschaft istlog.retention.hours, aber versuche es mit @ zu ...
Issue beim Verbinden von Kafka von außen
Ich verwende hortonwork Sandbox für einen Kafka-Server, der versucht, Kafka von Eclipse mit Java-Code zu verbinden. Verwenden Sie diese Konfiguration, um eine Verbindung zum Produzenten herzustellen und die Nachricht @ zu ...
Wie überprüfe ich, ob ZooKeeper ausgeführt wird oder von der Eingabeaufforderung aus?
Ich habe ein paar Optionen zum Einrichten von Kafka erkundet und wusste, dass der Zookeeper betriebsbereit sein muss, um einen Kafka einzuleiten. Ich würde gerne wissen, wie ich das unten finden kann. 1) Hostname und Port für meine ...
org.apache.spark.SparkException: Task nicht serialisierbar
Dies ist ein funktionierendes Codebeispiel: JavaPairDStream<String, String> messages = KafkaUtils.createStream(javaStreamingContext, zkQuorum, group, topicMap); messages.print(); JavaDStream<String> lines = ...
Entfernen einer Kafka-Verbrauchergruppe in zookeeper
Ich verwende kafka_2.9.2-0.8.1.1 mit zookeeper 3.4.6. Gibt es ein Dienstprogramm, mit dem eine Verbrauchergruppe automatisch aus zookeeper entfernt werden kann? Oder kann ich einfach alles unter / consumer / [group_id] in zookeeper entfernen? ...
Kafka: Holen Sie sich einen Broker-Host von ZooKeeper
Aus bestimmten Gründen muss ich beide verwenden -ConsumerGroup (a.k.a. High-Level-Verbraucher) undSimpleConsumer (a.k.a. Low-Level-Verbraucher) von Kafka zu lesen. ZumConsumerGroup Ich benutze die ZooKeeper-basierte Konfiguration und bin damit ...
Wie ändere ich den Startoffset für das Thema?
Ist es möglich, den Startoffset für ein neues Thema zu ändern? Ich möchte ein neues Thema erstellen und vom Offset aus lesen10000. Wie
Spark Python Avro Kafka Deserialiser
Ich habe einen Kafka-Stream in einer Python-Spark-App erstellt und kann jeden Text analysieren, der durch ihn kommt. kafkaStream = KafkaUtils.createStream(ssc, zkQuorum, "spark-streaming-consumer", {topic: 1})Ich möchte dies ändern, um ...
Kafka-Consumer-Abruf von Metadaten für Themen fehlgeschlagen
Ich versuche, einen Java-Client für die Kafka- und ZooKeeper-Server eines Drittanbieters zu schreiben. Ich kann Themen auflisten und beschreiben, aber wenn ich versuche, sie zu lesen, erscheint einClosedChannelException wird ausgelöst. Ich ...
Kafka mehrere Verbraucher für eine Partition
Ich habe einen Produzenten, der Nachrichten an ein Thema / eine Partition schreibt. Um die Bestellung aufrechtzuerhalten, möchte ich mit einer einzelnen Partition arbeiten und möchte, dass 12 Verbraucher alle Nachrichten von dieser einzelnen ...