ContacteÚs de l’artefacte Kafka amb KStreams
Navegació
| ⬅️ Productor / Consumidor | ➡️ Artefacte KTable |
|---|
Artefacte Kafka amb KStreams
Canigó – Artefacte de referència
Què és aquest artefacte?
Aquest artefacte amplia l’artefacte base de Productor / Consumidor Kafka incorporant Kafka Streams (KStreams) per realitzar processament en temps real sobre els esdeveniments.
Permet transformar missatges, filtrar informació i generar tòpics derivats de manera governada.
Què fa?
- Inclou productor i consumidor Kafka.
- Implementa KStreams per al processament d’esdeveniments.
- Permet:
- Filtrar esdeveniments.
- Transformar camps.
- Emmascarar o hashejar dades.
- Generar un o diversos tòpics de sortida.
- Manté la integració amb Avro i Schema Registry.
- Dona suport a la seguretat corporativa.
Quan utilitzar-lo?
Utilitza aquest artefacte quan:
- Necessitis processar esdeveniments en temps real.
- La lògica sigui simple o mitjana.
- No sigui necessari un estat complex o finestres avançades.
Guia ràpida d’ús
- Defineix els tòpics d’entrada i sortida a la configuració.
- Configura les regles de tractament (filtres, mappings, transformacions).
- Ajusta l’esquema Avro de sortida si aplica.
- Executa l’aplicació per iniciar el processament en streaming.
Descàrrega de l’artefacte
Data d'actualització:
01-01-0001