Resultados de la búsqueda a petición "spring-kafka"

2 la respuesta

¿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 ...

0 la respuesta

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 ...

2 la respuesta

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 ...

2 la respuesta

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 ...

1 la respuesta

¿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 ...

1 la respuesta

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 ...

1 la respuesta

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 ...

2 la respuesta

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>> ...

2 la respuesta

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 ...

1 la respuesta

¿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> ...