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 ...
Kafka incrustado: KTable + KTable leftJoin produce registros duplicados
Vengo a buscar el conocimiento de lo arcano. Primero, tengo dos pares de temas, con un tema en cada par alimentando al otro tema. Se están formando dos KTables por los últimos temas, que se utilizan en un KTable + KTable leftJoin. El problema es ...
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 ...
Leyendo el mismo mensaje varias veces de Kafka
yo sueloSpring Kafka API [http://docs.spring.io/spring-kafka/reference/htmlsingle/#_retrying_deliverieshttp://] para implementar Kafka Consumer con gestión manual de compensación: @KafkaListener(topics = "some_topic") public void ...
¿Por qué el consumidor de Kafka tarda tanto en comenzar a consumir?
Comenzamos un consumidor de Kafka, escuchando un tema que aún no se ha creado (aunque la creación automática de temas está habilitada). No mucho tiempo después, un productor publica mensajes sobre ese tema. Sin embargo, al consumidor le lleva ...
Consumidor de kafka de primavera, ¿busca compensación en tiempo de ejecución?
Estoy usando el KafkaMessageListenerContainer para consumir del tema kafka, tengo una lógica de aplicación para procesar cada registro que también depende de otros micro servicios. Ahora estoy confirmando manualmente el desplazamiento después de ...
Kafka en Kubernetes - Marcar al coordinador muerto para el grupo
Soy bastante nuevo en Kubernetes y quería configurar a Kafka y al cuidador del zoológico con él. Pude configurar Apache Kafka y Zookeeper en Kubernetes usando StatefulSets. Seguíesta ...
Spring @KafkaListener ejecuta y sondea registros después de cierto intervalo
Queríamos consumir los registros después de un cierto intervalo (por ejemplo, cada 5 minutos). Las propiedades de consumo son estándar: @Bean public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<Integer, String>> ...
Cómo escribir a los consumidores de Kafka: subprocesos individuales o subprocesos múltiples
He escrito un solo consumidor de Kafka (usando Spring Kafka), que lee de un solo tema y es parte de un grupo de consumidores. Una vez que se consume un mensaje, realizará todas las operaciones posteriores y pasará al siguiente desplazamiento del ...
¿Los mensajes de piedra sepulcral no eliminan el registro de la tienda de estado de KTable?
Estoy creando datos de procesamiento de KTable desde KStream. Pero cuando disparo mensajes de lápida con clave y carga útil nula, no se elimina el mensaje de KTable. sample - public KStream<String, GenericRecord> ...
Página 1 de 2