produce events to kafka
Project description
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_check
accepts url as parameter returns tuple True/False : Depending if connection is on or not String : Success or failure message
- – connect_to_kafka_producer
accepts url as parameter returns tuple True/False : Depending on producer status Obj/String : producer object if connected else error message
- – push_event_to_kafka
accepts eventData, topicName, producer as parameters returns tuple True/False : Depending if message published or not String : Success or failure message
Change log
0.0.1 (27/07/2023)
First Release
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.