kafkaproducerself 0.0.1

produce events to kafka

It provides general functions to get kafka producer and publish events using it, additonally a health check also there to make sure connections is live.

It provides three functions :

– health_checkaccepts url as parameter

returns tuple 1. True/False : Depending if connection is on or not 2. String : Success or failure message

– connect_to_kafka_produceraccepts url as parameter

returns tuple 1. True/False : Depending on producer status 2. Obj/String : producer object if connected else error message

– push_event_to_kafkaaccepts eventData, topicName, producer as parameters

returns tuple 1. True/False : Depending if message published or not 2. String : Success or failure message

Change log

0.0.1 (27/07/2023)

• First Release