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