HI Kafka Dev, I would like to request state check state so I can manage the Life Cycle of Producer better. I you guys agree I will file Jira request. I just give state of producer can be I would like mange or start (create new instance of producer) or restart or close based on state. I just gave example, you may add or remove states.
/*** * API TO CHECK STATE OF PRODUCER * @Return STATE.INIT_IN_PROGRESS STATE.INIT_DONE STATE.RUNNING STATE.CLOSE_REQUESTED STATE.CLOSE_IN_PROGRESS STATE.CLOSED */ public State getCurrentState(); Thanks, Bhavesh