Resultados da pesquisa a pedido "apache-kafka"
Falha na obtenção de metadados do consumidor Kafka para tópicos
Estou tentando escrever um cliente Java para os servidores Kafka e ZooKeeper de terceiros. Consigo listar e descrever tópicos, mas quando tento ler algum, umClosedChannelException é criado. Eu os reproduzo aqui com o cliente de linha de ...
Kafka vários consumidores para uma partição
Eu tenho um produtor que grava mensagens em um tópico / partição. Para manter o pedido, eu gostaria de ir com uma partição única e quero que 12 consumidores leiam todas as mensagens dessa partição única (nenhum grupo de consumidores, todas as ...
Início rápido do Kafka, advertised.host.name fornece kafka.common.LeaderNotAvailableException
Consigo obter um Kafka simples de um nó (kafka_2.11-0.8.2.1) trabalhando localmente em uma máquina Linux, mas quando tento executar um produtor remotamente, estou recebendo alguns erros confusos. Estou seguindo o guia de início rápido ...
Como uso vários consumidores no Kafka?
Sou um estudante novo que estuda Kafka e já deparei com algumas questões fundamentais para entender vários consumidores de que artigos, documentações etc. não foram muito úteis até agora. Uma coisa que tentei fazer é escrever meu próprio ...
Por que o desempenho do consumidor Kafka é lento?
Eu tenho um tópico simples e um consumidor e produtor Kafka simples, usando a configuração padrão. O programa é muito simples, tenho dois threads. No produtor, ele continua enviando dados de 16 bytes. E no lado do consumidor, ele continua ...
Qual comando mostra todos os tópicos e compensações das partições no Kafka?
Estou procurando um comando Kafka que mostre todos os tópicos e compensações das partições. Se é dinamicamente seria perfeito. No momento, estou usando o código java para ver essas informações, mas é muito inconveniente.
Monitoramento do kafka usando JMX ao executar o kafka no docker no boot2docker
Estou tentando fazer com que o monitoramento JMX funcione para monitorar uma instância kafka de teste. Tenho o kafka (ches / kafka) em execução no docker via boot2docker, mas não consigo configurar o monitoramento JMX corretamente. Fiz várias ...
Como monitorar o Kafka broker usando jmxtrans?
Kafka 0.8.1.1 (kafka_2.8.0-0.8.1.1.tgz) Estou usando o jmxtrans para fazer o monitoramento JMX de uma instância Kafka (que está sendo executada no docker). Infelizmente, as métricas kafka não estão sendo retornadas. Eu tentei algumas coisas ...
Como usar o KafkaSource do Flink no Scala?
Estou tentando executar um programa de teste simples com o KafkaSource da Flink. Estou usando o seguinte: Flink 0.9Scala 2.10.4Kafka 0.8.2.1Segui os documentos para testar o KafkaSource (dependência adicionada, agrupe o conector Kafka ...
java.lang.ClassNotFoundException: kafka.api.OffsetRequest
Estou recebendo o erro java.lang.ClassNotFoundException kafka.api.OffsetRequest ao tentar integrar o Kafka à nossa topologia Storm. Quais versões você está executando e está funcionando? Meu pom.xml <dependency> ...