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_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
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.