I am trying to filter out messages from the indexing topic which have a threat triage score > 50. For this, I have created a new JSONMap parser named 'notify_admin' and a Kafka topic named 'notify_admin'. I have set up the parser to get the messages from the indexing topic by specifying the 'sensorTopic' field. To send the message to the 'notify_admin' Kafka topic I have set the 'outputTopic'. However, when messages are sent to the indexing topic from other parsers I have configured for example squid they do get enriched and indexed but the JSON parser does not output any data to the Kafka topic. The JSON parser topology shows messages being emitted and acknowledged but no data is output to the 'notify_admin' Kafka topic What am I doing wrong?
For now, I am just trying to build up the flow pipeline so haven't set up any filter using Stellar. Just trying to pass the messages from one topic to another. However, it doesn't work.