Resultados de la búsqueda a petición "spring-kafka"
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 ...
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 ...
¿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> ...
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 ...
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>> ...
¿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 ...
¿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 ...
Ejemplo de prueba de Kafka incrustado simple con arranque de resorte
Editar FYI:ejemplo de trabajo de gitHub [https://github.com/YunaBraska/embedded-kafka-example] Estaba buscando en Internet y no pude encontrar un ejemplo funcional y simple de una prueba de Kafka integrada. Mi configuración es: Bota de ...
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 1 de 2