I have the following use case:
I am capturing some data from ActiveMQ bus and Storing it in ElasticSearch via Logstash.
I am capturing some data ("version number") via Kafka and storing it in ElasticSearch. This variable is only sent once and then if it changes, it gets sent again. I am using Logstash for this for ingestion.
I would now like to update my data coming in via ActiveMQ, to contain the version number from Kafka, and have the data stored in same index. I need the version number to be a global variable and add it as a separate field to the data coming via ActiveMQ.
Whats the best way to configure this?