Resultados da pesquisa a pedido "apache-kafka"
Como resolver um problema com __consumer_offsets inválidos com ponto de verificação e época do produtor em partições de __transaction_state
Tenho dois tipos de entradas de log no server.log Primeiro tipo: WARN Redefinindo o primeiro deslocamento sujo de__consumer_offsets-6 para registrar o deslocamento 918 desde que ocheckpointed deslocamento 903 é inválido. ...
Kafka Streams não incrementa o deslocamento em 1 ao produzir para o tópico
Eu implementei um processador de registro de cartas Kafka Dead simple Funciona perfeitamente ao usar registros produzidos pelo produtor do consol No entanto, acho que nossos aplicativos Kafka Streams não garantem que, produzindo registros ...
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 Stream Suprimir sessão-janela-agregação
Escrevi esse código em um aplicativo de fluxo Kafka: KGroupedStream<String, foo> groupedStream = stream.groupByKey(); groupedStream.windowedBy( SessionWindows.with(Duration.ofSeconds(3)).grace(Duration.ofSeconds(3))) .aggregate(() -> {...}) ...
KStream envia registro para vários fluxos (não Branch)
Existe uma maneira de fazer uma operação semelhante a uma ramificação, mas colocar um registro em cada fluxo de saída cujo predicado é avaliado como verdadeiro? Brach coloca o registro na primeira correspondência (documentação: um registro é ...
Como garantir que um cluster kafka esteja totalmente ativo?
Temos um cluster de cinco nós em execução na produção com três tratadores de zebra - todos são VMs. Temos que reiniciar o cluster frequentemente para obter algumas correções de hardwar screvemos um script ansible para desligar o cluster na ...
Consumidor Kafka que não retorna nenhum evento
O consumidor Scala kafka abaixo não está retornando nenhum evento dopoll ligar No entanto, o tópico está correto e posso ver eventos sendo enviados para o tópico usando o consumidor do ...
org.springframework.context.ApplicationContextException: falha ao iniciar o bean 'org.springframework.kafka.config.internalKafkaListenerEndpointRegistry
Estou desenvolvendoSpring Boot + Apache Kafka + Apache Zookeeper exemplo. Eu instalei / setupApache Zookeeper and Apache Kafka na minha máquina local do Windows. Peguei uma referência no ...
Kafka O consumidor não recebe dados quando um dos corretores está inativo
Kafka Quickstart [https://kafka.apache.org/quickstart] Usando o Kafka v2.1.0 no RHEL v6.9 O consumidor falha ao receber dados quando um dos corretores Kafka está inoperant Etapas realizadas: 1. Iniciar zookeeper 2. Inicie o Kafka-Server0 ...
luxos @Kafka: leia TODAS as partições em todas as instâncias de um aplicativo
Ao usar o KTable, os fluxos Kafka não permitem que as instâncias leiam de várias partições de um tópico específico quando o número de instâncias / consumidores é igual ao número de partições. Tentei fazer isso usando o GlobalKTable, o problema é ...