use python kafka producer instead of CLI producer