Flow is: Parser (including the parser class, and all transformations, including stellar transformations) -> Kafka (enrichments)
Kafka (enrichments) -> Enrichment topology with all it’s Stellary goodness -> Kafka (indexing) Kafka (indexing) -> Indexing topologies (ES / Solr / HDFS) configured based on the indexing config named the same as source.type -> wherever the indexer tells it to be. Simon > On 29 Jan 2018, at 11:53, Ali Nazemian <alinazem...@gmail.com> wrote: > > Thanks, Simon. When will it apply for the enrichment? Is that after parser > and post-parser Stellar implementation? I am trying to understand If I > change it in post-parser Stellar, will it be overwritten at the last step > of Parser topology or not? > > Cheers, > Ali > > On Mon, Jan 29, 2018 at 8:55 PM, Simon Elliston Ball < > si...@simonellistonball.com> wrote: > >> Yes, it is. >> >> Sent from my iPhone >> >>> On 29 Jan 2018, at 09:33, Ali Nazemian <alinazem...@gmail.com> wrote: >>> >>> Hi All, >>> >>> I was wondering how the routing mechanism works in Metron currently. Can >>> somebody please explain how Enrichment Storm topology understands a >> single >>> event is related to which Metron feed? What about indexing? is that based >>> on "source.type" field? >>> >>> Cheers, >>> Ali >> > > > > -- > A.Nazemian
