An example application for consuming the output of detection-count-stream-processor for SANS2D data.
Contains main script, PulseImage Flatbuffers python file and some simple unit tests.
By setting auto_offset_reset='earliest' as part of the Kafka Consumer set up, the application can proces historical data sent to the specified topic, with no processing required.
In order to access a live data stream, keep or return auto_offset_reset='latest'. Download and run the detection-count-stream-processor, connecting it to an active source of EventMessages. Setting the python script to consume from the output topic of the processor will allow you to view an animated image of the detector.
If the application has been set up correctly, the image will eventually look something like this:
