esgf_core_utils.config.kafka
============================

.. py:module:: esgf_core_utils.config.kafka


Classes
-------

.. autoapisummary::

   esgf_core_utils.config.kafka.KafkaConfig
   esgf_core_utils.config.kafka.KafkaConsumerConfig


Module Contents
---------------

.. py:class:: KafkaConfig(/, **data: Any)

   Bases: :py:obj:`pydantic.BaseModel`


   Kafka Config


   .. py:class:: Config

      .. py:attribute:: validate_by_name
         :value: True



      .. py:attribute:: validate_by_alias
         :value: True



      .. py:attribute:: extra
         :value: 'ignore'




   .. py:attribute:: bootstrap_servers
      :type:  str
      :value: None



   .. py:attribute:: enable_auto_commit
      :type:  bool
      :value: None



   .. py:attribute:: sasl_mechanism
      :type:  str
      :value: None



   .. py:attribute:: sasl_username
      :type:  str
      :value: None



   .. py:attribute:: sasl_password
      :type:  str
      :value: None



   .. py:attribute:: security_protocol
      :type:  str
      :value: None



.. py:class:: KafkaConsumerConfig(/, **data: Any)

   Bases: :py:obj:`KafkaConfig`


   Kafka Consumer Config


   .. py:attribute:: auto_offset_reset
      :type:  str
      :value: None



   .. py:attribute:: group_id
      :type:  str
      :value: None



   .. py:attribute:: debug
      :type:  str | None
      :value: None



   .. py:attribute:: log_level
      :type:  int | None
      :value: None