Bhavesh, 1. I would expect the behavior you're suggesting as well. Any fix for the JIRA should address this, and I raised that point when reviewing the current version of the patch.
2. It's currently marked for 0.8.3 so it probably won't make it into 0.8.2, especially if there isn't a patch for it ready soon. I think that's probably the right choice -- it's a pretty unusual corner case and the current behavior is annoying, but not a critical bug. -Ewen On Thu, Jan 8, 2015 at 10:59 PM, Bhavesh Mistry <mistry.p.bhav...@gmail.com> wrote: > Adding User Community to see if any one knows behavior of Producer for > issue #1) and status of 2). > > > Thanks, > > Bhavesh > > On Fri, Jan 2, 2015 at 12:37 PM, Bhavesh Mistry < > mistry.p.bhav...@gmail.com> > wrote: > > > Hi Kafka Dev Team, > > > > I am following-up with you guys regarding New (Java) Producer behavior in > > event of network or firewall rules. I just wanted to make Java Producer > > resilient of any network or firewall issues, and does not become > > single-point of failure in application: > > > > 1) Jira Issue https://issues.apache.org/jira/browse/KAFKA-1788 > > > > > > > https://issues.apache.org/jira/browse/KAFKA-1788?focusedCommentId=14259235&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-14259235 > > > > What should be the behavior of the Producer when it can not reach leader > > broker, but metadata reported broker is leader for that partition (via > > other broker) ? Should the record-error-rate be counted and Call Back > > should be called with error or not ? > > > > 1) *record-error-rate* metric remain zero despite following firewall > > rule. In my opinion, it should have called > > org.apache.kafka.clients.producer.Callback but I did not see that > happening > > either one or two are brokers not reachable. > > > > 2) Is jira ticket https://issues.apache.org/jira/browse/KAFKA-1788 > will > > be merged to 0.8.2 ? This will give the ability to close the producer in > > event of lost connectivity to broker if io thread misbehave (does not > end) > > ? > > > > Thanks for your help ! > > > > Thanks, > > Bhavesh > > > -- Thanks, Ewen
