Resultados da pesquisa a pedido "spring-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 ...
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 é ...
Página 2 do 2