.. _types:

Types
=====

.. autodata:: kafkastreamer.types.ObjectID

.. autoclass:: kafkastreamer.types.MessageContext
   :members:
   :member-order: bysource

.. autoclass:: kafkastreamer.types.MessageMeta
   :members:
   :member-order: bysource

.. autoclass:: kafkastreamer.types.Message
   :members:
   :member-order: bysource

.. autodata:: kafkastreamer.types.MessageSerializer

.. autodata:: kafkastreamer.types.PartitionKeySerializer

.. autodata:: kafkastreamer.types.Partitioner

.. autoclass:: kafkastreamer.RefreshFinalizeType
   :members:
   :member-order: bysource