Resultados da pesquisa a pedido "apache-kafka"
Consumidor Kafka - qual é a relação dos processos e threads do consumidor com as partições de tópicos
Eu tenho trabalhado com Kafka ultimamente e tenho um pouco de confusão em relação aos consumidores de um grupo de consumidores. O centro da confusão é se os consumidores devem ser implementados como processos ou threads. Para esta pergunta, ...
kafka perde todos os tópicos ao reiniciar
Estou testando o Kafka (0.8.2.1) em uma VM, mas estou tendo problemas com ele: apesar de tudo estar bem enquanto a máquina permanece ligada (mesmo se eu reiniciar o ZK / Kafka), se eu reiniciar a máquina (depois de fechar normalmente) ZK / Kafka) ...
Por que Kafka tão rápido [fechado]
Se eu tiver o mesmo hardware, use o Kafka ou nossa solução atual (ServiceMix / Camel). Existe alguma diferença? Kafka pode manipular dados "maiores" que ele? Por quê? Há um artigo para falar sobre quão rápido poderia ser? Mas ainda não ...
Apache Kafka com consumidor de alto nível: ignorar mensagens corrompidas
Estou enfrentando um problema com o consumidor kafka de alto nível (0.8.2.0) - depois de consumir uma certa quantidade de dados, um de nossos consumidores para. Após reiniciar, ele consome algumas mensagens e para novamente sem erro / exceção ou ...
Erro ao criar tópicos Kafka - fator de replicação maior que os corretores disponíveis
Estou tentando criar tópicos no Kafka, seguindo o guia no site do Apache Kafka através da linha de comando. Ao executar o comando: bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testEu ...
usando o protocolo mqtt com kafka como um intermediário de mensagens
Como podemos usar o protocolo mqtt com o kafka como um intermediário de mensagens? Os clientes (aplicativos Java para Android / iOS / desktop etc.) produzirão e consumirão mensagens usando as bibliotecas do lado do cliente mqtt phao, disponíveis ...
Erro Kafka na E / S java.io.EOFException: null
Estou usando o Kafka 0.8.2.0 (Scala 2.10). Nos meus arquivos de log, vejo a seguinte mensagem intermitentemente. Parece um problema de conectividade, mas estou executando ambos no meu host local. Esta é uma mensagem de aviso inofensiva ou devo ...
Kafka 0.8.2.2 - Não foi possível publicar mensagens
Escrevemos um cliente java para publicar mensagens no kafka. O código é como mostrado abaixo Properties props = new ...
Como excluir um tópico no apache kafka [duplicado]
Esta pergunta já tem uma resposta aqui: Excluir tópico no Kafka 0.8.1.1 [/questions/24287900/delete-topic-in-kafka-0-8-1-1] 13 respostasPreciso excluir um tópico no kafka-0.8.2.2.3. Eu usei o comando abaixo para excluir o ...
Como posso usar o Kafka para reter logs no logstash por um período mais longo?
Atualmente, uso redis -> s3 -> pesquisa elástica -> pilha kibana para canalizar e visualizar meus logs. Porém, devido ao grande volume de dados na pesquisa elástica, posso manter os registros por até 7 dias. Quero trazer o cluster kafka nessa ...