Resultados de la búsqueda a petición "spring-kafka"
¿Cómo probar un ConsumerAwareRebalanceListener?
Desarrollé un@KafkaListener que también está marcado con laConsumerAwareRebalanceListener interfaz, usando Spring Boot 2.0.6. Implementé elonPartitionsAssigned método, en el que rebobino el desplazamiento de una cantidad fija de tiempo, digamos ...
KStream envía el registro a varias transmisiones (no a Branch)
¿Hay alguna manera de hacer una operación similar a una rama pero colocar un registro en cada flujo de salida cuyo predicado se evalúa como verdadero? Brach coloca el registro en la primera coincidencia (documentación: se coloca un registro en ...
Página 2 de 2