Resultados da pesquisa a pedido "apache-kafka"
Atraso no consumidor consumindo mensagens no Apache Kafka
Estou usando o Kafka 0.8.0 e tentando alcançar o cenário abaixo mencionado. API JCA (atua como produtor e envia dados para) -----> Consumidor ------> HBase Estou enviando cada mensagem ao consumidor assim que buscar os dados usando o JCA ...
Consumidor de alto nível Kafka buscar todas as mensagens do tópico usando a API Java (equivalente a --from-begin)
Estou testando o Consumidor de Alto Nível Kafka usando o código ConsumerGroupExample do site Kafka. Eu gostaria de recuperar todas as mensagens existentes no tópico chamado "teste" que tenho na configuração do servidor Kafka. Olhando para outros ...
Como usar o Kafka 0.8 Log4j appender
Estou tentando executar o Kafka-0.8 Log4j appender e não consigo fazê-lo. Quero que meu aplicativo envie logs diretamente para o kafka via Log4j appender. Aqui está o meu log4j.properties. Como não encontrei nenhum codificador adequado, apenas o ...
Existe uma maneira fácil de instalar o Kafka no Windows?
Estou tentando instalarKafka [http://kafka.apache.org/]fila de mensagens no Windowspara testefinalidade (não para produção: D). Eu encontrei este artigo apenas sobre como instalar o Apache Kafka 0.8 ...
Como o Kafka é transmitido para muitos grupos de consumidores
Sou novo em Kafka e aprecio muitos esclarecimentos sobre o próximo caso. A documentação da Kafka diz no parágrafo "Posição do consumidor": "Nosso tópico é dividido em um conjunto de partições totalmente ordenadas, cada uma delas consumida por ...
Como alcançar a multilocação no contexto de Kafka e tempestade?
Quais são as melhores práticas para criar um aplicativo multilocatário no contexto de Kafka e storm? Por exemplo: criando tópico para cada inquilino e consumir bicos de vários tópicos (usando curinga).
Apache Kafka - KafkaStream no tópico / partição
Estou escrevendo o Kafka Consumer para aplicativos distribuídos de alta velocidade e alto volume. Eu tenho apenas um tópico, mas a taxa de mensagens recebidas é muito alta. Ter várias partições que atendem a mais consumidores seria apropriado ...
Kafka Streams - Como controlar melhor o particionamento do tópico de armazenamento de estado criado internamente?
As lojas do estado em Kafka Streams são criadas internamente. Os armazenamentos de estado são particionados por chave, mas não permitem fornecer particionamento diferentepor chave (no meu conhecimento). QUESTÕES Comocontrolar o número de ...
O Zookeeper é obrigatório para Kafka?
No Kafka, eu gostaria de usar apenas um único broker, tópico único e uma única partição com um produtor e vários consumidores (cada consumidor obtendo sua própria cópia dos dados do broker). Diante disso, eu não quero a sobrecarga de usar o ...
Falha do consumidor único Kafka em um grupo
Estou nas fases iniciais de exploração do Kafka, versão 0.8.1.1. Executei com êxito o Exemplo de Grupo de Consumidores, com várias partições e suas mensagens de distribuição entre os consumidores muito bem. Um caso de teste que eu queria ...