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

Reply via email to