Update kafka-fs-producer.py