Resultados de la búsqueda a petición "apache-kafka-streams"
Pedido de particiones múltiples Kafka
Soy consciente de que no es posible ordenar múltiples particiones en Kafka y que el orden de las particiones solo está garantizado para un solo consumidor dentro de un grupo (para una sola partición). Sin embargo, con Kafka Streams 0.10, ¿ahora ...
¿Es una buena práctica realizar consultas de sincronización de base de datos o llamadas relajantes en trabajos de Kafka streams?
Utilizo transmisiones de Kafka para procesar datos en tiempo real, en las tareas de transmisiones de Kafka, necesito acceder a MySQL para consultar datos y llamar a otro servicio tranquilo. Todas las operaciones son sincrónicas. Me temo que ...
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 ...
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 ...
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 ...
Kafka Streams y RPC: ¿llamar al servicio REST en el operador map () se considera un antipatrón?
El enfoque ingenuo para implementar el caso de uso de enriquecer un flujo entrante de eventos almacenados en Kafka con datos de referencia es llamarmap() operador de un API de REST de servicio externo que proporciona estos datos de referencia, ...
Kafka Streams - ¿Cómo controlar mejor la partición del tema de la tienda de estado creado internamente?
Las tiendas estatales en Kafka Streams se crean internamente. Los almacenes de estado se dividen por clave, pero no permiten proporcionar particiones que no seanpor clave (que yo sepa). PREGUNTAS Cómocontrolar el número de particiones de un ...
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 ...
¿Cómo registrar un procesador sin estado (que parece requerir también un StateStore)?
Estoy construyendo una topología y quiero usarKStream.process () [https://kafka.apache.org/0100/javadoc/org/apache/kafka/streams/kstream/KStream.html#process(org.apache.kafka.streams.processor.ProcessorSupplier,%20java.lang.String...)] escribir ...
¿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 ...