• Streamer class
  • Streamer
    • Streamer.topic
    • Streamer.exclude
    • Streamer.include
    • Streamer.static_fields
    • Streamer.select_related
    • Streamer.prefetch_related
    • Streamer.handle_related
    • Streamer.batch_class
    • Streamer.refresh_finalize_type
    • Streamer.id_field
    • Streamer.enumerate_ids_field
    • Streamer.enumerate_chunk_field
    • Streamer.enumerate_chunk_size
    • Streamer.batch_size
    • Streamer.message_serializer
    • Streamer.partition_key_serializer
    • Streamer.partitioner
• Functions
  • send()
  • send_create()
  • send_update()
  • send_delete()
  • send_refresh()
  • full_refresh()
  • set_context()
  • stop_handlers()
  • is_model_handler_stopped()
  • get_registry()
  • get_streamer()
  • get_streamer_for_related()
  • squash()
• Decorators
  • register()
  • admin_site()
• Constants
  • kafkastreamer.TYPE_CREATE
  • kafkastreamer.TYPE_UPDATE
  • kafkastreamer.TYPE_DELETE
  • kafkastreamer.TYPE_REFRESH
  • kafkastreamer.TYPE_ENUMERATE
  • kafkastreamer.TYPE_EOS
• Types
  • ObjectID
  • MessageContext
    • MessageContext.source
    • MessageContext.user_id
    • MessageContext.extra
  • MessageMeta
    • MessageMeta.timestamp
    • MessageMeta.msg_type
    • MessageMeta.context
  • Message
    • Message.meta
    • Message.obj_id
    • Message.data
  • MessageSerializer
  • PartitionKeySerializer
  • Partitioner
  • RefreshFinalizeType
    • RefreshFinalizeType.ENUMERATE
    • RefreshFinalizeType.EOS
• Celery Tasks
  • refresh()
  • refresh_model()