papfa

• papfa package
  • Subpackages
    • papfa.middlewares package
      • Submodules
      • papfa.middlewares.consumer module
      • papfa.middlewares.producer module
      • Module contents
  • Submodules
  • papfa.cli module
    • configure_papfa()
    • get_list_of_consumers()
  • papfa.config module
    • KafkaConfig
      • KafkaConfig.bootstrap_servers
      • KafkaConfig.sasl_mechanism
      • KafkaConfig.sasl_password
      • KafkaConfig.sasl_username
      • KafkaConfig.security_protocol
    • KafkaConsumerConfig
      • KafkaConsumerConfig.deserialize_key
      • KafkaConsumerConfig.deserializer
      • KafkaConsumerConfig.group_id
      • KafkaConsumerConfig.kafka_config
      • KafkaConsumerConfig.topics
    • KafkaProducerConfig
      • KafkaProducerConfig.kafka_config
      • KafkaProducerConfig.serializer
    • SchemaRegistryConfig
  • papfa.consumers module
    • BaseConsumer
      • BaseConsumer.consume()
      • BaseConsumer.get_meta_data()
    • BatchConfig
      • BatchConfig.size
      • BatchConfig.timeout
    • ConfluentAvroDeserializer
      • ConfluentAvroDeserializer.deserialize()
    • Deserializer
    • KafkaConsumer
      • KafkaConsumer.commit()
      • KafkaConsumer.consume()
      • KafkaConsumer.consumer
      • KafkaConsumer.consumer_name
      • KafkaConsumer.exit_gracefully()
      • KafkaConsumer.flush()
      • KafkaConsumer.get_meta_data()
    • MessageHandler
      • MessageHandler.handle_batch()
      • MessageHandler.is_satisfy()
    • consumer()
    • get_default_kafka_consumer()
  • papfa.dtos module
    • Record
      • Record.headers
      • Record.key
      • Record.meta
      • Record.timestamp
      • Record.value
  • papfa.papfa module
  • papfa.producers module
    • KafkaMessageProducer
      • KafkaMessageProducer.flush()
      • KafkaMessageProducer.get_config()
      • KafkaMessageProducer.produce()
      • KafkaMessageProducer.producer
    • KafkaMessageTransactionalProducer
      • KafkaMessageTransactionalProducer.Transaction
      • KafkaMessageTransactionalProducer.get_config()
      • KafkaMessageTransactionalProducer.transaction()
    • MessageProducer
      • MessageProducer.produce()
    • get_message_producer()
    • get_message_transactional_producer()
  • papfa.settings module
    • Papfa
      • Papfa.get_config()
      • Papfa.get_configs()
      • Papfa.get_default_or_raise_bad_config()
      • Papfa.get_instance()
      • Papfa.papfa_configured()
      • Papfa.setup()
  • papfa.utils module
    • import_string()
    • make_function_from_path()
  • Module contents
    • Papfa
      • Papfa.get_config()
      • Papfa.get_configs()
      • Papfa.get_default_or_raise_bad_config()
      • Papfa.get_instance()
      • Papfa.papfa_configured()
      • Papfa.setup()
    • consumer()
    • get_message_producer()
    • get_message_transactional_producer()