Ich bin nicht klar , warum wir beide brauchen session.timeout.msund max.poll.interval.msund wann würden wir verwenden eine oder das andere oder beides? Anscheinend geben beide Einstellungen die Obergrenze für die Zeit an, die der Koordinator wartet, um den Herzschlag eines Verbrauchers zu...
Ich habe einige Optionen zum Einrichten von Kafka untersucht und wusste, dass der Zookeeper betriebsbereit sein muss, um ein Kafka zu initiieren. Ich würde gerne wissen, wie ich das unten finden kann. 1) Hostname und Port für meine Zookeeper-Instanz --- Ich habe die Datei zoo.cfg überprüft und...
Ich habe den Befehl zum Löschen eines Themas ausgegeben: ./bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic vip_ips_alerts Es schien eine glückliche Antwort zu geben: [2014-05-31 20:58:10,112] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient) Topic...
Ich muss einen Weg finden, Kafka nach einer Liste von Themen zu fragen. Ich weiß, dass ich das mit dem kafka-topics.shim bin\Verzeichnis enthaltenen Skript tun kann . Sobald ich diese Liste habe, brauche ich alle Verbraucher pro Thema. Ich konnte weder ein Skript in diesem Verzeichnis noch eine...
Ich lerne etwas über Kafka und lese hier den Einführungsabschnitt https://kafka.apache.org/documentation.html#introduction speziell der Teil über Verbraucher. Im vorletzten Absatz der Einleitung heißt es Kafka macht es besser. Durch den Begriff der Parallelität - der Partition - innerhalb der...
Ich habe noch keine Erfahrung mit * MQs und möchte Kenntnisse über JMS und Nachrichtenwarteschlangen im Allgemeinen aufbauen. Auf diese Weise frage ich mich, ob ich mit ActiveMQ beginnen oder es einfach ganz "ignorieren" und mir zunächst Apollo beibringen soll. Ist Apollo so funktionsreich wie...
Geschlossen . Diese Frage muss fokussierter sein . Derzeit werden keine Antworten akzeptiert. Möchten Sie diese Frage verbessern? Aktualisieren Sie die Frage so, dass sie sich nur auf ein Problem konzentriert, indem Sie diesen Beitrag bearbeiten . Geschlossen...
Ich verwende Confluent.Kafka .NET Client Version 1.3.0. Ich folge den Dokumenten : var consumerConfig = new ConsumerConfig { BootstrapServers = "server1, server2", AutoOffsetReset = AutoOffsetReset.Earliest, EnableAutoCommit = true, EnableAutoOffsetStore = false, GroupId = this.groupId,...
Ich erhalte ständig FETCH_SESSION_ID_NOT_FOUND. Ich bin mir nicht sicher, warum es passiert. Kann mir hier jemand gefallen, was das Problem ist und welche Auswirkungen es auf Verbraucher und Makler haben wird. Kafka Server Log: INFO [2019-10-18 12:09:00,709] [ReplicaFetcherThread-1-8][]...
Ich habe eine einfache App mit zwei Funktionen, eine zum Anhören von Themen und eine für Webendpunkte. Ich möchte serverseitiges Ereignis-Streaming (SSE) erstellen, dh Text- / Ereignis-Stream, damit ich es auf Client-Seite mit EventSource abhören kann. Ich habe vorerst den folgenden Code, in dem...
Ich habe das Dokument durchgearbeitet, von dem ich verstanden habe, dass wir mit Enabling genau einmal eine Transaktion erzielen können idempotence=true idempotence: Der Idempotent-Produzent aktiviert genau einmal für einen Produzenten ein einzelnes Thema. Grundsätzlich hat jede einzelne...
Beim Definieren einer Topologie in Kafka-Streams kann ein globaler Statusspeicher hinzugefügt werden. Es wird ein Quellthema sowie ein ProcessorSupplier. Der Prozessor empfängt Datensätze und kann sie theoretisch transformieren, bevor er sie dem Speicher hinzufügt. Im Falle einer Wiederherstellung...