how to write kafka producer in python