Resultados da pesquisa a pedido "apache-kafka"
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 ...
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 ...
Kafka: escrevendo serializador personalizado
Estou tentando criar um POC com o Kafka 0.8.1. Estou usando minha própria classe java como uma mensagem Kafka que possui vários tipos de dados String. Não posso usar a classe serializador padrão ou a classe Stringizer que vem com a biblioteca ...
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 ...
Erro de exemplo do Apache Kafka: falha ao enviar mensagem após 3 tentativas
Estou executando este exemplo de produtor kafka mencionado em seu site O código: public class TestProducer { public static void main(String[] args) { long events = Long.parseLong(args[0]); Random rnd = new Random(); Properties props = ...
Quando / como um tópico "marcado para exclusão" é finalmente removido?
Emiti o comando para excluir um tópico: ./bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic vip_ips_alerts Pareceu dar uma resposta feliz: [2014-05-31 20:58:10,112] INFO zookeeper state changed ...