Resultados da pesquisa a pedido "apache-kafka"
Como testar um ConsumerAwareRebalanceListener?
Eu desenvolvi um@KafkaListener que também está marcado com oConsumerAwareRebalanceListener interface, usando o Spring Boot 2.0.6. Eu implementei oonPartitionsAssigned, no qual rebobino o deslocamento de um período fixo de tempo, digamos 60 ...
Como buscar o esquema do conector de origem Kafka com base no nome do conector
Estou usando o conector Confluent JDBC Kafka para publicar mensagens no tópico. O conector de origem enviará dados para o tópico junto com o esquema em cada pesquisa. Quero recuperar esse esquema. É possível? Quão? Alguém pode me sugerir inha ...
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 é ...
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 ...
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 ...
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 ...
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 ...
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(() -> {...}) ...
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 ...