I have design data flow to fetch data from twitter and put in kafka, getting data in json format but not user specific.
1) That processor stream live data or old data ?
2) if processor stream live data then how to stream old data ?
3) how to fetch user specific incremental data using gettwitter processor ?
4) if my flow failed some times then how to stream that specific time and live data using gettwitter processor ?