Resultados da pesquisa a pedido "apache-kafka"

2 a resposta

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 ...

6 a resposta

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: ...

2 a resposta

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 ...

4 a resposta

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 ...

3 a resposta

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 ...

2 a resposta

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"); ...

2 a resposta

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 ...

1 a resposta

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 é ...

3 a resposta

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 ...

2 a resposta

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) ...