Resultados de la búsqueda a petición "apache-kafka-streams"
¿Cómo agregar un StateStore personalizado al procesador DSL de Kafka Streams?
Para una de mis aplicaciones de transmisión de Kafka, necesito usar las funciones de DSL y la API del procesador. El flujo de mi aplicación de transmisión es source -> selectKey -> filter -> aggregate (on a window) -> sinkDespués de ...
Kafka Streams - Enviar sobre diferentes temas dependiendo de los datos de Streams
Tengo una aplicación de secuencias de kafka esperando que se publiquen registros sobre el temauser_activity. Recibirá datos json y, dependiendo del valor de una clave, quiero insertar esa secuencia en diferentes temas. Este es mi código de la ...
Consultas externas del sistema durante el procesamiento de Kafka Stream
Estoy tratando de diseñar una arquitectura de transmisión para análisis de transmisión. Requisitos: Entrada de datos de transmisión RT y NRTProcesadores de flujo que implementan algunos análisis financierosFlujo de salida de análisis RT y ...
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 ...
¿Cómo hacer la agregación en una ventana deslizante basada en conteo de tamaño fijo?
¿Cómo implemento una agregación de ventana deslizante (o transformación) con una ventana basada en conteo de tamaño fijo? Por ejemplo: si tengo datos de transmisión como el siguiente input stream = 1,2,3,4,5,6,7,8...Suponga que el tiempo no es ...
¿Cómo conectarse a múltiples clústeres en una sola aplicación Kafka Streams?
En elGuía para desarrolladores de Kafka Streams [https://docs.confluent.io/current/streams/developer-guide/config-streams.html] dice: Las aplicaciones de Kafka Streams solo pueden comunicarse con un solo clúster de Kafka especificado por este ...
Cómo manejar el error y no comprometerse cuando use Kafka Streams DSL
Para Kafka Streams, si usamos una API de procesador de nivel inferior, podemos controlar la confirmación o no. Entonces, si ocurren problemas en nuestro código, y no queremos confirmar este mensaje. En este caso, Kafka reenviará este mensaje ...
Filtrado de flujos de Kafka: ¿corredor o consumidor?
Estoy mirando las corrientes de kafka. Quiero filtrar mi flujo, usando un filtro con muy baja selectividad (uno en unos pocos miles). Estaba mirando este ...
Kafka Streaming Concurrency?
Tengo un código básico de Kafka Streaming que lee registros de un tema, procesa y envía registros a otro tema. ¿Cómo maneja Kafka streaming la concurrencia? ¿Todo se ejecuta en un solo hilo? No veo esto mencionado en la documentación. Si es de ...
¿Cómo administrar Kafka KStream a Kstream con ventana?
Residencia enApache Kafka docs [https://kafka.apache.org/documentation/streams#streams_dsl_joins] KStream-to-KStream Joins are always windowed joins, mi pregunta es ¿cómo puedo controlar el tamaño de la ventana? ¿Es del mismo tamaño para ...