Hi Kafka Dev Team,
The use case is that we need to know producer state in background Threads
and so we can submit the message.
This seems to a bug in trunk code. I have notice that KafkaProducer itself
does not have close state and inflight message will encounter following
issues. Should I file bug for this issue ?
java.lang.IllegalStateException: Cannot send after the producer is closed.
at
org.apache.kafka.clients.producer.internals.RecordAccumulator.append(RecordAccumulator.java:136)
at
org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:237)
.................................................
at java.util.TimerThread.mainLoop(Timer.java:555)
at java.util.TimerThread.run(Timer.java:505)
Thanks,
Bhavesh
On Sun, Oct 5, 2014 at 3:30 PM, Bhavesh Mistry <mistry.p.bhav...@gmail.com>
wrote:
> 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
>
