Resultados da pesquisa a pedido "apache-kafka"
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 ...
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 ...
Opções de API do Kafka Create Topic para idiomas não Java
Enquanto você pode criar um tópico via Java ou linguagens baseadas em Java (consulteaqui [https://stackoverflow.com/questions/18225263/kafka-0-8-is-it-possible-to-create-topic-with-partition-and-replication-using-j] ), não parece haver uma ...
Dados de replicação do Oracle usando o Apache kafka
Gostaria de expor a tabela de dados do meu banco de dados oracle e expor no apache kafka. é tecnicamente possível? Também preciso transmitir dados alterados da minha tabela oracle e notificá-los para Kafka. você conhece boa documentação deste ...
Kafka incorporado: KTable + KTable leftJoin produz registros duplicados
Eu venho buscando o conhecimento do arcano. Primeiro, eu tenho dois pares de tópicos, com um tópico em cada par alimentando o outro tópico. Dois KTables estão sendo formados pelos últimos tópicos, que são usados em um KTable + KTable leftJoin. 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 ...
Não é possível ver o mBean kafka.consumer e kafka.producer no jConsole
EDIT:Eu venho a conhecer t [https://stackoverflow.com/questions/37799564/kafka-consumer-jmx-properties]Para ativar o JMX em meus processos de Consumidor e Produtor e obter informações do mBean dos respectivos processos. Como faço isso para uma ...
Como criar um produtor com capacidade de reinicialização?
A versão mais recente do kafka suporta exatamente uma vez semântica (EoS). Para apoiar essa noção, detalhes extras são adicionados a cada mensagem. Isso significa que no seu consumidor; se você imprimir deslocamentos de mensagens, elas não serão ...
Kafka: Não é possível criar vários consumidores de fluxo
Acabei de me levantar e correr com o Kafka 0.8 beta 1. Eu tenho um exemplo muito simples em funcionamento, o problema é que eu só posso obter um consumidor d...