Index

B

BaseConsumer (class in papfa.consumers)

BatchConfig (class in papfa.consumers) bootstrap_servers (papfa.config.KafkaConfig attribute)

C

commit() (papfa.consumers.KafkaConsumer method) configure_papfa() (in module papfa.cli) ConfluentAvroDeserializer (class in papfa.consumers) consume() (papfa.consumers.BaseConsumer method) (papfa.consumers.KafkaConsumer method)

ConsumedMessageStatsMiddleware (class in papfa.middlewares.consumer) consumer (papfa.consumers.KafkaConsumer property) consumer() (in module papfa) (in module papfa.consumers) consumer_name (papfa.consumers.KafkaConsumer property) ConsumerMiddleware (class in papfa.middlewares.consumer)

D

deserialize() (papfa.consumers.ConfluentAvroDeserializer method) deserialize_key (papfa.config.KafkaConsumerConfig attribute)

Deserializer (class in papfa.consumers) deserializer (papfa.config.KafkaConsumerConfig attribute)

E

exit_gracefully() (papfa.consumers.KafkaConsumer method)

F

flush() (papfa.consumers.KafkaConsumer method) (papfa.producers.KafkaMessageProducer method)

G

get_config() (papfa.Papfa method) (papfa.producers.KafkaMessageProducer method) (papfa.producers.KafkaMessageTransactionalProducer method) (papfa.settings.Papfa method) get_configs() (papfa.Papfa method) (papfa.settings.Papfa method) get_default_kafka_consumer() (in module papfa.consumers) get_default_or_raise_bad_config() (papfa.Papfa method) (papfa.settings.Papfa method) get_instance() (papfa.Papfa class method) (papfa.settings.Papfa class method)

get_list_of_consumers() (in module papfa.cli) get_message_producer() (in module papfa) (in module papfa.producers) get_message_transactional_producer() (in module papfa) (in module papfa.producers) get_meta_data() (papfa.consumers.BaseConsumer method) (papfa.consumers.KafkaConsumer method) group_id (papfa.config.KafkaConsumerConfig attribute) (papfa.middlewares.consumer.MessageKey attribute)

H

handle_batch() (papfa.consumers.MessageHandler method)

headers (papfa.dtos.Record attribute)

I

import_string() (in module papfa.utils)

is_satisfy() (papfa.consumers.MessageHandler method)

K

kafka_config (papfa.config.KafkaConsumerConfig attribute) (papfa.config.KafkaProducerConfig attribute) KafkaConfig (class in papfa.config) KafkaConsumer (class in papfa.consumers) KafkaConsumerConfig (class in papfa.config)

KafkaMessageProducer (class in papfa.producers) KafkaMessageTransactionalProducer (class in papfa.producers) KafkaMessageTransactionalProducer.Transaction (class in papfa.producers) KafkaProducerConfig (class in papfa.config) key (papfa.dtos.Record attribute)

M

make_function_from_path() (in module papfa.utils) MessageHandler (class in papfa.consumers) MessageKey (class in papfa.middlewares.consumer) MessageProducer (class in papfa.producers) meta (papfa.dtos.Record attribute) module papfa papfa.cli papfa.config papfa.consumers papfa.dtos papfa.middlewares papfa.middlewares.consumer papfa.middlewares.producer papfa.papfa papfa.producers papfa.settings papfa.utils

P

papfa module Papfa (class in papfa) (class in papfa.settings) papfa.cli module papfa.config module papfa.consumers module papfa.dtos module papfa.middlewares module papfa.middlewares.consumer module papfa.middlewares.producer module papfa.papfa module

papfa.producers module papfa.settings module papfa.utils module papfa_configured() (papfa.Papfa class method) (papfa.settings.Papfa class method) process_after_flush() (papfa.middlewares.consumer.ConsumedMessageStatsMiddleware method) (papfa.middlewares.consumer.ConsumerMiddleware method) process_after_produce() (papfa.middlewares.producer.ProducerMiddleware method) process_before_batching() (papfa.middlewares.consumer.ConsumerMiddleware method) process_before_flush() (papfa.middlewares.consumer.ConsumedMessageStatsMiddleware method) (papfa.middlewares.consumer.ConsumerMiddleware method) process_before_poll() (papfa.middlewares.consumer.ConsumerMiddleware method) process_before_produce() (papfa.middlewares.producer.ProducerMiddleware method) produce() (papfa.producers.KafkaMessageProducer method) (papfa.producers.KafkaMessageTransactionalProducer.Transaction method) (papfa.producers.MessageProducer method) producer (papfa.producers.KafkaMessageProducer property) ProducerMiddleware (class in papfa.middlewares.producer)

R

Record (class in papfa.dtos)

S

sasl_mechanism (papfa.config.KafkaConfig attribute) sasl_password (papfa.config.KafkaConfig attribute) sasl_username (papfa.config.KafkaConfig attribute) SchemaRegistryConfig (class in papfa.config)

security_protocol (papfa.config.KafkaConfig attribute) serializer (papfa.config.KafkaProducerConfig attribute) setup() (papfa.Papfa method) (papfa.settings.Papfa method) size (papfa.consumers.BatchConfig attribute)

T

timeout (papfa.consumers.BatchConfig attribute) timestamp (papfa.dtos.Record attribute)

topic (papfa.middlewares.consumer.MessageKey attribute) topics (papfa.config.KafkaConsumerConfig attribute) transaction() (papfa.producers.KafkaMessageTransactionalProducer method)

V

value (papfa.dtos.Record attribute)