.. _streamer:

Streamer class
==============

.. autoclass:: kafkastreamer.Streamer
   :members: topic, exclude, include, static_fields, select_related, prefetch_related, handle_related, batch_class, refresh_finalize_type, batch_size, message_serializer, partition_key_serializer, partitioner, id_field, enumerate_ids_field, enumerate_chunk_field, enumerate_chunk_size
   :member-order: bysource

.. _KafkaProducer documentation: https://kafka-python.readthedocs.io/en/master/apidoc/KafkaProducer.html