Ús de l’artefacte Kafka amb KStreams i KTables
Navegació
| ⬅️ KStreams | ➡️ Inici EventHub |
|---|
Artefacte Kafka amb KStreams i KTables
Canigó – Artefacte de referència
Què és aquest artefacte?
Aquest artefacte amplia l’ús de KStreams incorporant KTables, permetent realitzar joins entre fluxos i taules per enriquir esdeveniments en temps real.
Està pensat per a escenaris de major complexitat funcional.
Què fa?
- Inclou productor i consumidor Kafka.
- Implementa:
- KStreams per a fluxos d’esdeveniments.
- KTables per a dades de referència.
- Permet realitzar joins (inner / left) entre streams i taules.
- Genera esdeveniments enriquits en tòpics de sortida.
- Manté la integració amb Avro, Schema Registry i seguretat.
Quan utilitzar-lo?
Utilitza aquest artefacte quan:
- Necessitis enriquir esdeveniments amb dades de referència.
- Requereixis joins entre diferents fonts.
- El cas d’ús no es pugui resoldre només amb KStreams.
Guia ràpida d’ús
- Defineix el tòpic que actuarà com a KTable.
- Configura el camp d’unió entre stream i taula.
- Selecciona el tipus de join (inner o left).
- Ajusta l’esquema Avro de l’esdeveniment resultant.
- Executa l’aplicació i valida els resultats en els tòpics de sortida.
Descàrrega de l’artefacte
Data d'actualització:
01-01-0001