Resultados da pesquisa a pedido "apache-kafka"
não é possível conectar ao servidor kafka
Eu tento usar o Kafka com a versão 0.9.0 com a porta 9092. Se eu usar o telnet, eu me conecto com sucesso a esse endereço, mas não consigo me conectar ao servidor Kafka com a API Java Aqui está meu exemplo de Java, use exatamente a documentação ...
É possível usar várias associações à esquerda na consulta Confluent KSQL? tentou ingressar no stream com mais de 1 tabelas, se não, então qual é a solução?
Corrente : describe ammas; Field | Type ------------------------------------- ROWTIME | BIGINT (system) ROWKEY | VARCHAR(STRING) (system) ID | INTEGER -------------------------------------Para estatísticas de tempo de execução e detalhes da ...
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"); ...
Quando o cliente Apache Kafka lança uma exceção "Expiração em lote"?
Usando o cliente Apache Kafka Java (0.9), estou tentando enviar uma longa série de registros para o broker usando oKafka Producer class [https://kafka.apache.org/090/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html] . O ...
Como passar dados do Kafka para o Spark Streaming?
Estou tentando passar dados de kafka para desencadear streaming. Isto é o que eu fiz até agora: Instalou amboskafka esparkComeçadozookeeper com configuração de propriedades padrãoComeçadokafka server com configuração de propriedades ...
Conexão entre Apache Kafka e JMS
Eu queria saber se o Apache Kafka poderia se comunicar e enviar mensagens para o JMS? Posso estabelecer conexão entre eles? Por exemplo, estou usando o JMS no meu sistema e ele deve enviar mensagens para o outro sistema que usa o Kafka
Como permitir que diferentes contêineres do Docker se comuniquem sem expor as portas ao mundo inteiro
Eu precisava testar meukafka acionadores de consumidor e mensagem em um ambiente controlado. Então eu fiz umansible projeto para criar alguns mockkafka servidores:mokafelk [https://github.com/xialingxiao/mokafelk]. Funciona bem, exceto que a ...
Vários consumidores Kafka podem ler a mesma mensagem da partição
Planejamos gravar um consumidor Kafka (java) que leia a fila Kafka para executar uma ação que esteja na mensagem. Como os consumidores operam independentemente, a mensagem será processada por apenas um consumidor por vez? Caso contrário, todos ...
kafka.consumer.SimpleConsumer: reconexão devido a erro de soquete: java.nio.channels.ClosedChannelException
Estou executando um consumidor simples para kafka como este: int timeout = 80000; int bufferSize = 64*1024; consumer = new SimpleConsumer(host, port,timeout, bufferSize, clientName);Isso funciona bem por algumas horas, mas recebo uma exceção ...
Como configurar o log para produtores Kafka?
Estou usando o cliente produtor Kafka e não tenho nenhuma configuração log4j no meu projeto. Em execução, o programa imprime muitos logs do Kafka Debug que eu realmente não quero. Então, tentei adicionar um log4j.properties para definir o nível ...