preguntar acerca de apache-zookeeper
2
réponses
Pourquoi les consommateurs de Kafka se connectent-ils à zookeeper et les producteurs obtiennent-ils des métadonnées auprès des courtiers?
Pourquoi les consommateurs se connectent - ils à zookeeper pour récupérer les emplacements de partition? Et les producteurs de kafka doivent se connecter à l'un des courtiers pour récupérer les métadonnées.
Mon point est, Quelle est exactement l'uti …
demandé sur
1970-01-01 00:33:35
6
réponses
Pourquoi zookeeper n’utilise-t-il pas mon répertoire log4j. properties
Dans mon fichier zookeeper/conf/log4j.properties, j'ai défini le zookeeper.journal.dir à $HOME / zklogs
Quand j'utilise zkServer.sh il n'utilise pas ce répertoire. Au lieu de cela, il utilise le ${ZOO_LOG_DIR} qui, quand je l'écho, sort à"."
Je ne …
demandé sur
1970-01-01 00:33:34
3
réponses
Comment exécuter HBase shell contre un cluster distant
J'exécute HBase en mode pseudo-distribué sur mon poste de travail. Nous avons aussi HBase tournant sur un cluster. En utilisant le shell HBase, j'aimerais accéder à L'instance HBase qui fonctionne sur le cluster depuis mon poste de travail. Je vou …
demandé sur
1970-01-01 00:33:32
6
réponses
ZooKeeper pour Java / config de printemps?
y a-t-il des cas bien documentés D'utilisation D'Apache Zokeeper pour distribuer la configuration des applications Java, et en particulier les services Spring?
ResourcePropertySource et l'insérer dans un Printemps contexte. Notez que cela ne refléte …
demandé sur
1970-01-01 00:33:32
2
réponses
Zokeeper & Kafka error KeeperErrorCode=NodeExists
j'ai écrit un kafkaconsumer et producer ça fonctionne très bien jusqu'à aujourd'hui.
Ce matin, quand j'ai commencé zooekeeper et kafka, ma consommation n'a pas réussi à lire les messages et en Zookeeper log j'ai lu cette erreur
INFO Got user-level K …
demandé sur
1970-01-01 00:33:35
2
réponses
Kafka — comment engager offset après chaque message en utilisant le consommateur de haut niveau?
j'utilise le consommateur de haut niveau de Kafka. Parce que J'utilise Kafka comme une "file d'attente de transactions" pour mon application, je dois absolument m'assurer que je ne manque pas ou relire des messages. J'ai 2 questions au sujet de ceci: …
demandé sur
1970-01-01 00:33:34
4
réponses
Comment créer un sujet dans Kafka à travers Java
je veux créer un thème dans Kafka (kafka_2.8.0-0.8.1.1) par java. Cela fonctionne bien si je crée un sujet dans l'invite de commande, et si je pousse le message à travers l'api java. Mais je veux créer un sujet à travers l'api java. Après une longue …
demandé sur
1970-01-01 00:33:34
7
réponses
Comment obtenir des données à partir de l’ancien offset point à Kafka?
j'utilise zookeeper pour obtenir des données de kafka. Et ici je reçois toujours des données du dernier point de décalage. Est-il possible de spécifier le temps de décalage pour récupérer les anciennes données?
il y a une option autooffset.r …
demandé sur
1970-01-01 00:33:33
13
réponses
Production de numéros de séquence distribués?
j'ai généralement mis en œuvre sequence number generation en utilisant des séquences de base de données dans le passé.
p.ex. utilisant le type de série http://www.neilconway.org/docs/sequences /
je suis curieux cependant co …
demandé sur
1970-01-01 00:33:30
6
réponses
Hbase erreur zookeeper existe en échec après 3 retiries
j'utilise le mode autonome HBASE 0.94.8 en Ubuntu. Je suis capable de faire toutes les opérations dans Hbase-shell. Mais après je me suis connecté de mon système son donnant l'erreur suivante
15/07/28 15:10:30 ERROR zookeeper.RecoverableZooKee …
demandé sur
1970-01-01 00:33:35