I am trying to implement a pipeline with this kind of architecture:
Tracker > Kafka collector > Kafka topic no1 > Kafka enricher (with api enrichment) > Kafka topic no2 > Kafka enricher (with another api enrichment) > Kafka topic no3
First of allo is it possible for an enricher to consume an already enriched event and perform another enrichment? I have trouble with deserialization because i think the results of the first enrichment are in a TSV format and the second enricher awaits data in thrift format.
How is it possible to perform two consecutive API enrichments for the same event?
Thank you in advance!