Resultados da pesquisa a pedido "apache-zookeeper"
Resolvendo o mestre principal do Mesos
Estamos usando o Mesos para executar tarefas em um cluster. Estamos usando haproxy para apontar, por exemplo,mesos.seanmcl.com para um mestre do Mesos. Se esse mestre não for o líder, a interface do usuário redirecionará o navegador, após ...
Usando o Zookeeper com Solr, mas só tem 2 servidores
Eu sou novo no Solr e estou experimentando o SolrCloud - e parece que o ZooKeeper é a melhor maneira de gerenciar alta disponibilidade. No entanto, em nosso ambiente de produção, temos apenas dois servidores (ativo-ativo) e estou preocupado que ...
Problema do tratador na definição de kafka
Para instalar o kafka, baixei a pasta tar do kafka. Para iniciar o servidor, tentei este comando: bin/zookeeper-server-start.sh config/zookeeper.propertiesO seguinte erro ocorreu ao inserir o comando acima: INFO Reading configuration from: ...
UnknownHostException kafka
Estou tentando configurar um cluster Kafka (o primeiro nó no cluster, na verdade). Eu tenho uma configuração de cluster do zookeeper de nó único. Estou configurando o kafka em um nó separado. Ambos rodando o CentOS 6.4, rodando o IPV6, que é um ...
Hbase conexão sobre erro zookeeper
Ambiente: Ubuntu 14.04, hadoop-2.2.0, hbase-0.98.7 quando inicio o hadoop e o hbase (modo de nó único), ambos bem-sucedidos (também verifico o site 8088 para hadoop, 60010 para hbase) jps 4507 SecondaryNameNode 5350 HRegionServer 4197 NameNode ...
Como criar um tópico no Kafka através de Java
Quero criar um tópico no Kafka (kafka_2.8.0-0.8.1.1) através do java. Está funcionando bem se eu criar um tópico no prompt de comando e se eu enviar mensagem através da API Java. Mas eu quero criar um tópico através da API Java. Depois de uma ...
Consumir do Kafka com falha O Iterator está no estado de falha
Estou recebendo exceção ao consumir as mensagens do kafka. org.springframework.messaging.MessagingException: Consuming from Kafka failed; nested exception is java.util.concurrent.ExecutionException: java.lang.IllegalStateException: Iterator is ...
Um arquivo de instantâneo do ZooKeeper é suficiente para restaurar o estado?
Estou aprendendo sobre o ZooKeeper e procurando opções para fazer backup de dados armazenados no ZooKeeper. O ZooKeeper grava dois arquivos de dados, instantâneo e log de transações. É frequentemente mencionado que os instantâneos são "difusos" e ...
Throuput lento do consumidor ao usar 2 configurações de consumidor
Usando a extensão spring-integration-kafka e a seguinte configuração: <int-kafka:zookeeper-connect id="zookeeperConnect" zk-connect="#{kafkaConfig['zooKeeperUrl']}" zk-connection-timeout="10000" zk-session-timeout="10000" zk-sync-time="2000" /> ...
Como configurar propriedades dinâmicas ao usar a bota de mola?
Estou planejando usar o Spring Boot para minha tarefa. É um aplicativo de servidor típico com conexão ao banco de dados. Eu sei que posso usarConfiguração da ...