Dominar Kafka Streams y ksqlDB

Capítulo 7. API del procesador

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

Hace sólo unos capítulos, nos embarcamos en nuestro viaje para aprender sobre Kafka Streams. Empezamos con el DSL de alto nivel de Kafka Streams, que nos permite construir aplicaciones de procesamiento de flujos utilizando una interfaz funcional y fluida. Esto implica componer y encadenar funciones de procesamiento de flujos utilizando los operadores integrados de la biblioteca (por ejemplo, filter, flatMap, groupBy, etc.) y abstracciones (KStream, KTable, GlobalKTable).

En este capítulo, exploraremos una API de nivel inferior que está disponible en Kafka Streams: la API de procesador (a veces llamada PAPI). La API Procesadora tiene menos abstracciones que el DSL de alto nivel y utiliza un estilo imperativo de programación. Aunque el código suele ser más prolijo, también es más potente, ya que nos proporciona un control detallado sobre lo siguiente: cómo fluyen los datos a través de nuestras topologías, cómo se relacionan entre sí los procesadores de flujos, cómo se crea y mantiene el estado, e incluso la temporización de determinadas operaciones.

Algunas de las preguntas a las que responderemos en este capítulo son:

• ¿Cuándo debes utilizar la API del Procesador?

• ¿Cómo se añaden procesadores fuente, sumidero y flujo utilizando la API de procesadores?

• ¿Cómo puedes programar funciones periódicas?

• ¿Es posible mezclar la API del ...