Resultados da pesquisa a pedido "apache-kafka"
Integração Kafka Spring: cabeçalhos que não chegam para o consumidor kafka
Estou usando o Kafka Spring Integration para publicar e consumir mensagens usando o kafka. Vejo que a carga útil é passada corretamente do produtor para o consumidor, mas as informações do cabeçalho estão sendo substituídas em ...
Kafka kafka.common.MessageSizeTooLargeException at consumer
Para algumas mensagens maiores, encontrei o seguinte erro: kafka.common.MessageSizeTooLargeException: Message size is 1185198 bytes which exceeds the maximum configured message size of 1000012.Então, conformeesta ...
O streaming do Apache Flink no cluster não divide tarefas com trabalhadores
Meu objetivo é configurar um cluster de alto rendimento usando o Kafka como fonte e o Flink como o mecanismo de processamento de fluxo. Aqui está o que eu fiz. Eu configurei um cluster de 2 nós com a seguinte configuração no mestre e ...
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) ...
Como listar produtores em kafka
Assim como o Kafka Offset Monitor pode mostrar uma lista de consumidores ativos de um tópico, existe alguma ferramenta ou interface de linha de comando ou algo que possa listar o nome dos produtores que publicam em um determinado tópico?
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 ...
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 ...
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 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 ...
diferença entre groupid e consumerid em Kafka consumidor
Eu sou novo em Kafka. Notei na configuração do consumidor que tem dois IDs. um é group.id (obrigatório) e o segundo é consumer.id (não obrigatório). Diga por que 2 IDs e diferença.