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 ...
¿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 ...
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 ...
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 ...
¿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> ...
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 ...
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 ...
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 ...
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 ...
Spring Kafka Producer no envía a Kafka 1.0.0 (Magic v1 no admite encabezados de registro)
Estoy usando esta configuración docker-compose para configurar Kafka localmente: https://github.com/wurstmeister/kafka-docker/ [https://github.com/wurstmeister/kafka-docker/] docker-compose up funciona bien, crear temas a través de shell ...
Página 1 de 2