Re: QOS on Producer Side

The new producer should work with the 0.8.0 broker. Thanks, Jun On Tue, May 6, 2014 at 11:30 AM, Bhavesh Mistry wrote: > So to retrieve the message that was not transmitted due to error, I will > have to store the message in each call back the message and store this in a > file.Is there an

Re: Review Request 20997: Fix KAFKA-1432: address Neha's comments

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/20997/#review42376 --- system_test/utils/kafka_system_test_utils.py

[jira] [Updated] (KAFKA-1179) createMessageStreams() in javaapi.ZookeeperConsumerConnector does not throw

[ https://issues.apache.org/jira/browse/KAFKA-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sriharsha chintalapani updated KAFKA-1179: -- Status: Patch Available (was: Open) > createMessageStreams() in javaapi.Zookee

[jira] [Updated] (KAFKA-1179) createMessageStreams() in javaapi.ZookeeperConsumerConnector does not throw

[ https://issues.apache.org/jira/browse/KAFKA-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sriharsha chintalapani updated KAFKA-1179: -- Attachment: KAFKA-1179-v1.patch > createMessageStreams() in javaapi.ZookeeperCo

Re: Review Request 21134: Fix KAFKA-1432: follow-up on producer shutdown issue

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21134/#review42413 --- Ship it! Ship It! - Neha Narkhede On May 6, 2014, 11:05 p.m., Gu

Re: git commit: kafka-1384; Log Broker state; patched by Timothy Chen; reviewed by Joel Koshy and Jun Rao

I think we forgot to commit the new BrokerState file. On Tue, May 6, 2014 at 4:36 PM, wrote: > Repository: kafka > Updated Branches: > refs/heads/trunk 44c39c4ea -> 9b6bf4078 > > > kafka-1384; Log Broker state; patched by Timothy Chen; reviewed by Joel > Koshy and Jun Rao > > > Project: http: