With this exercise you will connect two streams: (1) a stream of TaxiRide events and (2) a query stream on which you can type queries (a query being an integer n on a line by itself). The expected output is all rides which, at the time the query is processed, started at least n minutes ago (in event time) and haven’t yet ended.
On MacOS and Linux you can start the broadcast query stream via
nc -lk 9999
and on Windows you can install ncat from https://nmap.org/ncat/ and then use
ncat -lk 9999
There’s no integration test for this exercise. How might you go about testing your solution?
Reference solutions are available at GitHub: