Resultados de la búsqueda a petición "apache-kafka-streams"
Conectar dinámicamente un flujo de entrada de Kafka a múltiples flujos de salida
¿Existe una funcionalidad integrada en Kafka Streams que permita conectar dinámicamente una única secuencia de entrada en múltiples secuencias de salida?KStream.branch permite la ramificación basada en predicados verdaderos / falsos, pero esto no ...
¿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 ...
Probar la topología de Kafka Streams
Estoy buscando una forma de probar una aplicación Kafka Streams. Para poder definir los eventos de entrada y el conjunto de pruebas me muestra la salida. ¿Es esto posible sin una configuración real de Kafka?
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 ...
¿Cómo comprometerse manualmente con Kafka Stream?
¿Hay alguna manera de comprometerse manualmente con Kafka Stream? Por lo general, con el uso deKafkaConsumer, Hago algo como a continuación: while (true) { ConsumerRecords<String, String> records = consumer.poll(100); ...
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 ...
Transmisión de mensajes a múltiples temas
Tengo un solo tema maestro y múltiples predicados, cada uno de los cuales tiene un tema de salida asociado. Quiero enviar cada registro a TODOS los temas cuyo predicado se resuelva en verdadero. Estoy usando Luwak para probar qué predicados ...
¿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 ...
Manejo de mensajes incorrectos con la API de Streams de Kafka
Tengo un flujo de procesamiento de flujo básico que se parece a master topic -> my processing in a mapper/filter -> output topicsy me pregunto cuál es la mejor manera de manejar "mensajes malos". Esto podría ser cosas como mensajes que no puedo ...
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 ...