Tag: apache-zookeeper

Apache ZooKeeper ist ein verteilter Dienst, der eine Konfiguration der Aufbewahrung der Informationen, Namensgebung, Synchronisation, Koordination und Gruppe Dienste.

Wie auf ein Zookeeper-ensemble als "super" - Benutzer über Tierpfleger shell?

Anzahl der Antworten 2 Antworten
Pro die Tierpfleger docs, kann man den Zugriff auf die ein Zookeeper-ensemble als "super" - Benutzer. Die Richtungen, dies zu tun, sind ein wenig vage, sowohl in Bezug auf die Konfiguration und Anschlusstechnik. Es hat dezent darauf

Apache Curator Implementierte Fehler Beim Erstellen zNodes

Anzahl der Antworten 5 Antworten
Ich versuche, Apache zu nutzen Kurator mit einem dockerized zookeeper-Instanz und egal wie ich es Versuch ich immer am Ende mit einem org.apache.Tierpfleger.KeeperException$UnimplementedException: KeeperErrorCode = Unimplemented für... Fehler. Ich habe versucht, Einblick in die Dokumentation, aber ich

KafkaSpout nicht empfangen etwas von Kafka

Anzahl der Antworten 4 Antworten
Ich versuche, mich zu manipulieren, bis ein ein Kafka-Sturm "Hello World" system. Ich habe Kafka installiert ist und läuft, wenn ich Daten senden, mit der Kafka-producer Lesen kann ich es mit der Kafka-Konsole Verbraucher. Nahm ich die

Tierpfleger immer EndOfStreamException, verursacht einen Absturz

Anzahl der Antworten 1 Antworten
Meine Tierpfleger steuert ein paar verschiedene Warteschlangen für unterschiedliche jobs, indem das relevante job-Daten in jedem Knoten, bis der computer bereit ist, zu verarbeiten. Wenn ich aufhöre, den gesamten service, so dass keine jobs gestartet werden kann

Apache Kafka: Fehler beim Aktualisieren der Metadaten/java.nio.- Kanäle.ClosedChannelException

Anzahl der Antworten 1 Antworten
Ich fange gerade mit Apache Kafka/Tierpfleger und läuft in Probleme, die versuchen, eine cluster on AWS. Momentan habe ich drei Server: Einer mit Tierpfleger und zwei Laufenden Kafka. Kann ich anfangen die Kafka-Servern ohne Problem und können

Tierpfleger nicht ab, nohup Fehler

Anzahl der Antworten 2 Antworten
Habe ich Heruntergeladen zookeeper-3.4.5.tar.gz und nach Extraktion ich schrieb conf/zoo.cfg als tickTime=2000 dataDir=/var/zookeeper clientPort=2181 Nun habe ich versucht zu starten Tierpfleger durch bin/zkServer.sh starten es gibt mohit@mohit:~/zookeeper-3.4.5/bin$ sudo sh zkServer.sh start [sudo] password for mohit: JMX enabled

Tierpfleger ist nicht eine anerkannte option, wenn die Ausführung kafka-console-consumer.sh

Anzahl der Antworten 3 Antworten
Bin ich zum lernen, wie kafka von dieser link(außer ich bin mit port 2182 in Tierpfleger), aber es zeigt: Tierpfleger ist nicht eine anerkannte option nach Ausführung: sudo ./bin/kafka-console-consumer.sh --Thema-test --Tierpfleger localhost:2182 Wie es zu lösen ist?

INFO Geschlossene socket-Verbindung für client /127.0.0.1:48452 hatte sessionid 0x15698f5ac360001 (org.apache.Tierpfleger.server.NIOServerCnxn)

Anzahl der Antworten 1 Antworten
Ich frisch installiert, Tierpfleger & kafka beiden. Ich begann Sie beide. Dann, wenn ich will, um zu sehen, die Liste der Themen, die mit diesem Befehl: bin/kafka-topics.sh --list --zookeeper localhost 2181 Es gibt mir die socket-Verbindung geschlossen.

Wie zu verwenden upconfig & linkconfig Skripte auf externen zookeeper

Anzahl der Antworten 2 Antworten
Ich versuche zum einrichten einer solrCloud mit externen zookeeper ensemble von 3 Servern und replizierten solr auf 2 Servern. Davon ausgegangen, dass eine externe zookeeper sollte unabhängig von anderen Speicher habe ich nicht herausfinden können, wie die

Kann nicht gestartet werden, Tierpfleger

Anzahl der Antworten 5 Antworten
Ich bin mit konfluent-Plattform, die Tierpfleger aktiv mit status-lookup. aber wenn ich versuche zu starten kafka mit konfluent es zeigt Tierpfleger ist down. $ sudo service zookeeper status Redirecting to /bin/systemctl status zookeeper.service ● zookeeper.service - Zookeeper

Tierpfleger unable to open socket auf localhost/0:0:0:0:0:0:0:1:2181

Anzahl der Antworten 2 Antworten
Ich bin mit zookeeper ensemble für hbase. Tierpfleger läuft auf 3 Maschinen. Während HBase ist auch in vollständig verteilten Modus. Ich habe Nutch 2.x-version. Wenn ich starten nutch zum Crawling einige Daten, gibt es folgende buggs in

Wie man Python kazoo Bibliothek?

Anzahl der Antworten 1 Antworten
Ich bin der Planung auf die Verwendung von Python kazoo-Bibliothek für Tierpfleger. Es ist alles über die Python-Frage hier nicht Tierpfleger an alle ich denke, die Bedeutung, wie die Verwendung von Python kazoo richtig.. Ich bin vollkommen

Tierpfleger/Mollig -vs - MySql-NDB

Anzahl der Antworten 2 Antworten
Habe ich gelesen, das Paxos Papier, das FLP-theorem, etc. vor kurzem und Evaluierung von Apache Zookeeper für ein Projekt. Ich habe auch schon thru Mollige (Google verteilten locking-service) und in der verschiedenen Literatur über ihn, das auch

Verbindung zum Tierpfleger in einem Apache Kafka Multi-Node-cluster

Anzahl der Antworten 2 Antworten
Habe ich die folgenden Anweisungen, um eine multi-Knoten-kafka-cluster. Nun, wie verbindet man die Tierpfleger ? Ist es in Ordnung, eine Verbindung zu nur einem Tierpfleger aus dem Producer/consumer-Seite in JAVA, oder gibt es eine Möglichkeit, schließen Sie

Ist Tierpfleger ein muss für Kafka?

Anzahl der Antworten 7 Antworten
In Kafka, ich möchte nur eine einzige broker, einziges Thema und eine einzige partition mit einem Erzeuger und mehrere Verbraucher (jeder Verbraucher erhält seine eigene Kopie der Daten, die vom broker). Angesichts dieser, ich will nicht den

Löschen/entfernen Solr Konfiguration von Tierpfleger mit zkcli?

Anzahl der Antworten 2 Antworten
Wir haben einige alte Solr Konfigurationen in ZK und das müssen wir bereinigen/löschen. Die configs sind unter /configs/AAA /configs/BBB, etc. (Es gibt auch andere configs unter /configs auch.) Den Solr zkcli.sh Skript und Google docs bieten keine

Kafka auf Kubernetes multi-node

Anzahl der Antworten 4 Antworten
Also mein Ziel hier ist ein cluster von mehreren kafka-Broker in einem Mode verteilt. Aber ich kann nicht sehen den Weg, um den Broker zu wissen, jeder anderen. Soweit ich das verstanden habe, jeder broker muss mit

entfernen einer kafka-consumer-Gruppe in Tierpfleger

Anzahl der Antworten 5 Antworten
Ich bin mit kafka_2.9.2-0.8.1.1 mit Tierpfleger 3.4.6. Gibt es ein Dienstprogramm, das automatisch entfernen kann ein Verbraucher Gruppe von zookeeper? Oder kann ich einfach entfernen Sie alles unter /Verbraucher/[group_id] in Tierpfleger? Wenn letzteres, gibt es etwas, was

Ändern Schema.xml in der SolrCloud setup

Anzahl der Antworten 3 Antworten
wie ändere ich das schema.xml für eine collection in SolrCloud? Ich habe ein zookeeper-ensemble auf 3 Knoten und ich glaube, ich könnte dort die Veränderungen vornehmen, aber weiß nicht genau. soweit ich weiß, nach dem ändern des

Kafka zum Tierpfleger-Befehl erzeugt Fehler

Anzahl der Antworten 5 Antworten
bin/kafka-topics.sh --create --topic activityTopic --zookeeper localhost:2181/kafka --partitions 1 --replication-factor 1 Den oben genannten Befehl aus kafka einen Fehler produziert Error while executing topic command org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/ids org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/ids

Wie die Flucht Schrägstrich in java, so dass es für den Einsatz im Pfad

Anzahl der Antworten 5 Antworten
Ich versuche zu entkommen Schrägstrich im String eingesetzt werden können, Weg mit Java. Zum Beispiel: String:: "Test/World" Jetzt will ich mit obigen string Pfad.Zur gleichen Zeit habe ich, um sicherzustellen, dass "Test/World" wird kommen, wie es ist,

Gute Tierpfleger Hallo Welt-Programm mit Java-client

Anzahl der Antworten 5 Antworten
Ich versuchte zu verwenden Tierpfleger in unserem Projekt. Könnte den server..Sogar testen Sie es mit zkcli.sh .. Alles gute.. Konnte aber nicht finden eine gute Anleitung für mich um die Verbindung zu diesem server mit Java !

testen kafka von Konsumenten und Produzenten Verbindung fehlgeschlagen

Anzahl der Antworten 6 Antworten
Habe ich versucht zu testen, ein kafka-installation und die Verwendung der erstellten guide Produzent und Verbraucher. Wenn Sie versuchen zum abrufen einer Nachricht bekomme ich folgende Fehlermeldung: WARN Session 0x0 for server null, unexpected error, closing socket

UnknownHostException kafka

Anzahl der Antworten 2 Antworten
Ich bin versucht, setup-eine Kafka-cluster (der erste Knoten im cluster eigentlich). Ich habe eine single-node-zookeeper-cluster-setup. Ich bin einrichten kafka auf einem separaten Knoten. Beiden läuft CentOS 6.4, läuft IPV6-das ist ein bisschen ein PITA. Ich habe überprüft,

KeeperErrorCode = NoNode für /admin/preferred_replica_election

Anzahl der Antworten 2 Antworten
wenn ich ab kafka,zookeeper Fehler passiert. INFO Got user-level KeeperException when processing sessionid:0x156028651c00001 type:delete cxid:0x1b zxid:0x59 txntype:-1 reqpath:n/a Error Path:/admin/preferred_replica_election Error:KeeperErrorCode = NoNode for /admin/preferred_replica_election (org.apache.zookeeper.server.PrepRequestProcessor) Eine ähnliche Frage (tl;dr es ist kein Fehler, nur eine info

Nach Linux-Neustart, Kafka werfen "keine Makler gefunden, wenn Sie versuchen, um ins Gleichgewicht bringen"

Anzahl der Antworten 6 Antworten
Folgte ich einer hervorragende Schritt-für-Schritt-Anleitung für die Installation von Kafka auf Linux. Alles funktionierte gut für mich, bis ich Linux neu gestartet. Nach dem Neustart bekomme ich die folgende Fehlermeldung, wenn ich versuche, Sie zu konsumieren, eine

Fehler in der Veröffentlichen Nachricht zum Thema Kafka

Anzahl der Antworten 6 Antworten
Ich bin neu auf Kafka und versuchen, setup-Umgebung für Sie . Ich versuche zu laufen, die einen einzelnen Knoten Kafka, aber ich bin immer Fehler in diesem. Folgenden folgenden Schritte auf mac 1. brew install zookeeper 2.

Wie wollen Sie ein backup Tierpfleger?

Anzahl der Antworten 5 Antworten
Habe ich gelesen, dass das kopieren der Daten Verzeichnis arbeiten. Aber, das ist eine Kombination von logs und snapshots. Wie tun Leute, eine Sicherungskopie von einem Tierpfleger-Infrastruktur ? Export ? Dump ? Benutzerdefinierte Skript ? Was sind

Wie zum ausführen von HBase shell für eine remote-cluster

Anzahl der Antworten 3 Antworten
Ich bin mit HBase in pseudo-distributed mode auf meiner workstation. Wir haben auch HBase in einem cluster ausgeführt. Mit der HBase shell, ich möchte den Zugriff auf die HBase-Instanz, die die im cluster ausgeführt von meiner workstation.

Wie zu installieren Kafka auf Windows?

Anzahl der Antworten 11 Antworten
Ich versuche zu installieren Kafka message-queue unter Windows für die Prüfung Zwecke (nicht für die Produktion). Fand ich diesen Artikel auf, wie zu installieren, Apache Kafka 0,8 auf Windows: http://janschulte.wordpress.com/2013/10/13/apache-kafka-0-8-on-windows/ Es ist ein guter Artikel, aber es

Konfigurieren von dynamischen Eigenschaften während der Verwendung von spring boot?

Anzahl der Antworten 3 Antworten
Ich bin Planung zu nutzen, Spring Boot für meine Aufgabe. Seine typische server-Anwendung mit Verbindung zur Datenbank. Ich weiß, dass ich verwenden können, Spring-Konfiguration zu externalisieren, meine Eigenschaften, z.B. db-Verbindung-details. Aber ich habe auch andere dynamische Eigenschaften,

Classpath ist noch leer. Bitte erstellen Sie das Projekt zunächst z.B. durch ausführen von './gradlew jar -PscalaVersion=2.11.12'

Anzahl der Antworten 5 Antworten
Ich bin nicht in der Lage zu laufen ein Apache Kafka service aufgrund eines Fehlers beim starten eine Zookeeper-Instanz. Ich habe heruntergeladen und versucht, es mit allen 3 verfügbaren downloads auf der offiziellen Seite. (binarys und Quelle),

Tierpfleger error connection Verlust Ausnahme

Anzahl der Antworten 2 Antworten
Bin ich mit einem SeqWare VM, die auf einer amazon EC2-instance-ich versuche, die SeqWare-Abfrage-engine zum Abfragen von Daten von VCF-Dateien. Wenn ich den ersten Start der Instanz und Folgen Sie den Anweisungen, um die Daten zu importieren,

Tierpfleger Verbindung zu localhost

Anzahl der Antworten 1 Antworten
Während der Ausführung Pig-Skript, das einfügen von Daten in HBase bekam ich folgenden Fehler. 2013-10-25 14:57:03,147 [main-SendThread(localhost:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) 2013-10-25 14:57:03,147

Wie, um das setup kafka und Tierpfleger auf Ihrem lokalen Rechner?

Anzahl der Antworten 1 Antworten
Habe ich installiert kafka und Tierpfleger auf meinem lokalen Laufwerk C:\ Ordner jetzt versuche ich zu laufen die Tierpfleger und kafka server, so kann ich Themen erstellen, aber seine werfen folgende Fehlermeldung, keine Ahnung, was läuft hier

Ab Zookeeper-Cluster. Fehler: Konnte nicht gefunden oder geladen werden Hauptklasse org.apache.Tierpfleger.server.Kollegium.QuorumPeerMain

Anzahl der Antworten 1 Antworten
(Ich bin läuft auf CentOS 5.8). Ich verfolge die Richtung für eine Clustered (Multiserver) Tierpfleger Set-up, aber erhalte eine Fehlermeldung, wenn ich versuche zu starten, meinen server. Wenn ich den Befehl ausführen wie in der Dokumentation beschrieben:

Tierpfleger.log-Datei nicht erstellt innerhalb logs-Verzeichnis

Anzahl der Antworten 1 Antworten
Ich bin nicht in der Lage zu erstellen Tierpfleger.Protokoll unter dem Verzeichnis, das ich angegeben hatte in der log4j.Eigenschaften. Ich bin mir nicht sicher, was schief geht, Kann jemand bitte mir direkt was sollte ich suchen in,

Wie bekomme ich alle in der Gruppe Liste mit kafka0.10.x

Anzahl der Antworten 1 Antworten
wenn ich kafka0.8.x,ich kann alle Gruppen-Prozess mit dem Tierpfleger durch den Pfad /consumers/group_id, da die offsets zu Begehen, zu Tierpflegerin in 0.8.x. Aber in der version 0.10.x-offsets verpflichtet kafka broker wie ein Pfad /brokers/topics/__consumer_offsets und Weg /consumers

Was ist die Rolle der Tierpfleger vs Eureka für microservices?

Anzahl der Antworten 2 Antworten
Werde ich die Umsetzung der Orchestrierung eine Reihe von microservices in meiner Anwendung. Zwei weit über die tools, die ich gefunden vs Apache Tierpfleger und Netflix Eureka. Kann jemand bitte geben Sie mir einen Vergleich, basierend auf

Kafka 1.0 Haltestellen mit FATALEN HERUNTERFAHREN-Fehler. Logs fehlgeschlagen

Anzahl der Antworten 6 Antworten
Ich habe nur ein Upgrade auf Kafka 1.0 und Tierpfleger 3.4.10.Auf den ersten, es begann alles in Ordnung. Stand - alone-Erzeuger-und Verbraucherpreise wie erwartet funktionierte. Nachdem ich habe mein code für etwa 10 Minuten, Kafka schlägt fehl

Habe die user-level KeeperException bei der Verarbeitung

Anzahl der Antworten 1 Antworten
Ich weiß, das wurde vor der Frage, so bitte vergib mir für das Fragen wieder, aber keine der Lösungen gezeigt, durch diesen thread für mich gearbeitet. Ich versuche, setup-Kafka 0.10.20 folgenden die docs. Wenn ich beginne, Tierpfleger,

Solr-Setup - Fehler: Konnte nicht gefunden oder geladen werden Hauptklasse org.apache.solr.cloud.ZkCLI

Anzahl der Antworten 7 Antworten
Ich bin nach dem tutorial einstellen, Solr (http://lucene.apache.org/solr/quickstart.html) mit Windows 7, Java-version 1.8 und Solr version 4.10.2. Java installiert ist C:\root\java und Solr installiert ist c:\root\solr-4.10.2. Habe ich 2 Umgebungsvariablen Benutzer-Variablen: CLASSPATH = C:\ROOT\solr-4.10.2\dist\solr-core-4.10.2.jar JAVA_HOME = c:\root\java

Kann keine Verbindung zum zookeeper und dann hbase master heruntergefahren

Anzahl der Antworten 1 Antworten
Ich verwenden hbase 0.94.1 und Tierpfleger 3.3.6 nachdem einige versuche, dem Meister der hbase heruntergefahren und die sw beendet Diese sind die Fehler, die ich aus der shell 12/09/26 18:58:35 INFO zookeeper.ZooKeeper: Initiating client connection, connectString=localhost:2181 sessionTimeout=180000

Tierpfleger Problem in der Einstellung kafka

Anzahl der Antworten 6 Antworten
Installieren kafka , die ich heruntergeladen habe die kafka-tar-Ordner. Um den server zu starten ich habe versucht diesen Befehl : bin/zookeeper-server-start.sh config/zookeeper.properties Folgende Fehler ist aufgetreten bei der Eingabe der oben genannten Befehl: INFO Reading configuration from:

nicht versuchen, die Authentifizierung mit SASL (unbekannter Fehler)

Anzahl der Antworten 2 Antworten
Ich bin versucht, setup-Tierpfleger auf ec2 zwei Instanzen. als gegeben hier und hier. Ich versuche zu laufen Tierpflegerin, die mit einem Fehler fehlschlägt: Befehl: bin/zkCli.sh -server localhost:2181 > 2015-03-15 00:22:35,644 [myid:] - INFO [main:ZooKeeper@438] - Initiating client

Kafka startup scheitert mit Tierpfleger timeout (remote server), dennoch kann die Maschine eine Verbindung zum zookeeper direkt

Anzahl der Antworten 2 Antworten
Wenn ich starten kafka, es schlägt schnell fehl, während beschwert, dass es keine Verbindung zum Tierpfleger. Ich bin mit Tierpfleger als ein eigenständiges cluster/ensemble. Ich bin verwirrt, weil es keine Firewall zwischen den Servern (wie bewiesen durch

Fehler während der Ausführung von Kafka auf Windows

Anzahl der Antworten 8 Antworten
Ich versuche zu laufen, Kafka auf Windows-Rechner und wenn ich versuche zu starten die Tierpfleger bin ich vor dieser seltsame Fehler . classpath leer ist. bitte erstellen Sie das Projekt zunächst z.B. durch laufen "gradlew jarall' Jede

Kafka Verbraucher in Spark Streaming

Anzahl der Antworten 5 Antworten
Beim schreiben einer Spark-Streaming-job, der verbraucht Nachrichten von Kafka. Hier ist, was ich habe, so weit: 1) Gestartet Tierpfleger. 2) Begann Kafka-Server. 3) Schickte ein paar Nachrichten an den server. Ich kann Sie sehen, wenn ich führen

Kafka : Wie Verbinde kafka-Konsole-Verbraucher zu Holen remote-broker Thema content?

Anzahl der Antworten 4 Antworten
Ich habe setup eine kafka Tierpfleger und 3 Broker auf einer Maschine, die auf ec2 mit ports 9092..9094 und versuche zu verbrauchen, das Thema von einer anderen Maschine. Die ports 2181 (zk), 9092, 9093 und 9094 (Server)

Wie zu Beginn hiveserver2 als service

Anzahl der Antworten 3 Antworten
Hallo alle, ich habe setup multi-node-cluster (ich.e 5 Knoten) in meinem Netzwerk, das gut funktioniert. jetzt wollte ich einfügen und abrufen von Daten aus cluster mithilfe von hive-so habe ich das setup hive neueste Version apache-hive-0.14.0-bin.tar.gz (d.h.