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