kp-fraydit 0.1.1

Kafka library for producing and consuming

This library makes working with kafka in python easy. It simplifies the producing of records. The producer class persists fields so that the fields of a record can be retrieved in various places from within your code base.

The library that expands on the work of Confluent's kafka-python library to make an intuitive producer that simplifies coding. This producer acts as a Super Class that you can inherit all of your specific producers in your code. The implementation takes five lines of code

• Set the KAFKA_REGISTRY_LISTENER and KAFKA_BROKER_LISTENER (2 lines of code)
• from kp_fraydit.producers.producer import Producer
• prod = Producer('my-topic')
• prod.addValueArgs(myField1='test')

That is all that is needed to produce a record.

It utilizes Confluent's amazing Exact-Once Semantics(EOS) architecture. That assurance takes time, however. To speed up the library, all producer instances pool their records and then the records are parallel processed. This enhances the speed of the library while maintaining the EOS assurance. The sacrifice of this pooling loses the guarantee of order preservation. The library allows for individual producer instances to maintain a separate pool that ensures order.

The producer handles JSON and Avro schema automatically. Nested schema (Avro only) is handled. That means you can have records within records and the producer class knows how to handle that.

You can discover what fields are available, which fields are required, optional fields, specify optional fields that you want to include on each write, all from within the attributes of the producer.

https://fraydit.com