Why I am facing [Errno 32] Broken pipe when I start new process? I am using confluent-kafka to process messages from kafka topic.
