I am implementing pushed based indexing model with druid index service.
I want to use index service to ingest data from both real time and batch sources. This will be done using tranquility. For real time data, I will be listening to rabbitmq and push data using tranquility finagle inteface. For batch operation I will be reading data from cassandra and push it using tranquility finagle interface.
My question is how to differentiate between realtime and batch operations ? Is there a way to configure DruidBeam to do, or it does not matter ?