Resultados da pesquisa a pedido "apache-kafka-streams"
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 é ...
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 é ...
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(() -> {...}) ...
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 ...