Resultados da pesquisa a pedido "apache-kafka"
Tópico Kafka por produtor
Vamos dizer que tenho vários dispositivos. Cada dispositivo possui diferentes tipos de sensores. Agora, quero enviar os dados de cada dispositivo para cada sensor para o kafka. Mas estou confuso sobre os tópicos kafka. Para processar esses dados ...
Problema do tratador na definição de kafka
Para instalar o kafka, baixei a pasta tar do kafka. Para iniciar o servidor, tentei este comando: bin/zookeeper-server-start.sh config/zookeeper.propertiesO seguinte erro ocorreu ao inserir o comando acima: INFO Reading configuration from: ...
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 ...
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 ...
Hive Crie vários arquivos pequenos para cada inserção no HDFS
o seguinte já foi alcançado Produtor Kafka que extrai dados do twitter usando o Spark Streaming.Consumidor Kafka que ingere dados na tabela Hive External (no HDFS).enquanto isso está funcionando bem até agora. há apenas um problema que estou ...
Karaf - Pacote Kafka OSGI - Edição do produtor
Estou tentando criar um pacote simples para o produtor Kafka no apache Karaf versão 4.0.3. Aqui está o meu código Java Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("acks", "all"); ...
Problema ao conectar kafka de fora
Estou usando hortonwork Sandbox para servidor kafka tentando conectar kafka do eclipse com código java. Use esta configuração para conectar-se ao produtor e enviar a ...
Como implementar o teste de contrato quando o kafka está envolvido na arquitetura de microsserviços?
Atualmente, estou trabalhando em um projeto em que temos a implementação kafka na arquitetura de micro serviços. Você conseguiu criar casos de teste de contrato para interação de tópicos mS a kafka usando pact-jvm? Minha implementação é ...
O tópico Kafka não existe mais após a reinicialização
Criei um tópico no cluster kafka local com 3 servidores / corretores executando o seguinte no diretório de instalação do kafka bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 2 --topic ...
Kafka Connect ficando sem espaço no heap
Depois de iniciar o Kafka Connect (connect-standalone), minha tarefa falha imediatamente após iniciar com: java.lang.OutOfMemoryError: Java heap space at java.nio.HeapByteBuffer.<init>(HeapByteBuffer.java:57) ...