=====================
OpenMSIStreamProducer
=====================

.. autoclass:: openmsistream.kafka_wrapper.OpenMSIStreamProducer