=====================
OpenMSIStreamConsumer
=====================

.. autoclass:: openmsistream.kafka_wrapper.OpenMSIStreamConsumer