Need someone to work on Kafka health probe in python

for every environment we need to create an SSL avro Producer/Consumer that posts data into a monioting topic,so if event is posted and consumed successfully print success status 0 and if it fails print [login to view URL] events 0/1 need to be posted to a database.