Dominar Kafka Streams y ksqlDB

Capítulo 3. Procesamiento sin estado

Este trabajo se ha traducido utilizando IA. Agradecemos tus opiniones y comentarios: [e-mail]

La forma más sencilla de procesamiento de flujos no requiere memoria de los eventos vistos anteriormente. Cada evento se consume, se procesa¹ y posteriormente se olvida. Este paradigma se denomina procesamiento sin estado, y Kafka Streams incluye un rico conjunto de operadores para trabajar con datos de forma sin estado.

En este capítulo, exploraremos los operadores sin estado que se incluyen en Kafka Streams y, al hacerlo, veremos cómo se pueden abordar con facilidad algunas de las tareas de procesamiento de flujos más comunes. Los temas que exploraremos incluyen:

• Filtrar registros

• Añadir y eliminar campos

• Reintroducir registros

• Arroyos ramificados

• Fusionar flujos

• Transformar registros en uno o varios productos

• Enriquecer los registros, de uno en uno

Adoptaremos un enfoque basado en tutoriales para introducir estos conceptos. En concreto, transmitiremos datos sobre criptomonedas desde Twitter y aplicaremos algunos operadores sin estado para convertir los datos sin procesar en algo más significativo: señales de inversión. Al final de este capítulo, comprenderás cómo utilizar operadores sin estado en Kafka Streams para enriquecer y transformar datos sin procesar, lo que te preparará para los conceptos más avanzados que exploraremos en capítulos posteriores.

Antes de pasar al tutorial, vamos a tener un mejor marco ...