Kafka Live Listeners#

Event and Histogram Listeners#

There are two new mechanisms for listening to live data in Mantid using the Apache Kafka distributed streaming platform. The KafkaEventListener and the KafkaHistoListener allow users to listen on a kafka stream for event and histogram data respectively. The process for using the listeners can be found in the documentation for StartLiveData.

Example Usage#

Below is an example of using the KafkaEventListener from a python script in Mantid:

StartLiveData(FromNow=False, FromStartOfRun=True, UpdateEvery=2, Instrument='SANS2D',
                Listener='KafkaEventListener', Address='sakura:9092', ProcessingAlgorithm='Rebin',
                ProcessingProperties='Params=0,1000,100000', AccumulationMethod='Replace',
                RunTransitionBehavior='Restart', OutputWorkspace='testout')

Release 4.0.0