[jira] [Created] (KAFKA-1040) ConsumerConfig and ProducerConfig do "work" in the Constructor

2013-09-04 Thread Sharmarke Aden (JIRA)
Sharmarke Aden created KAFKA-1040: - Summary: ConsumerConfig and ProducerConfig do "work" in the Constructor Key: KAFKA-1040 URL: https://issues.apache.org/jira/browse/KAFKA-1040 Project: Kafka

[jira] [Commented] (KAFKA-1039) kafka return acks but not logging while sending messages with compression

2013-09-04 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13757803#comment-13757803 ] Jun Rao commented on KAFKA-1039: It this the same problem as kafka-1037 when snappy jar is

[jira] [Created] (KAFKA-1041) Number of file handles increases indefinitely in producer if broker host is unresolvable

2013-09-04 Thread Rajasekar Elango (JIRA)
Rajasekar Elango created KAFKA-1041: --- Summary: Number of file handles increases indefinitely in producer if broker host is unresolvable Key: KAFKA-1041 URL: https://issues.apache.org/jira/browse/KAFKA-1041

[jira] [Assigned] (KAFKA-1041) Number of file handles increases indefinitely in producer if broker host is unresolvable

2013-09-04 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede reassigned KAFKA-1041: Assignee: Neha Narkhede (was: Jun Rao) > Number of file handles increases indefinitely

SAMZA-14

2013-09-04 Thread Jay Kreps
I have the QA torture jobs running. And all the various killings now work as expected (kafka, yarn rm, yarn nm, samza am, samza containers). One thing I didn't figure out was how to get gradle to build the tgz. What I have is just cut-and-pasted from the shell package: https://reviews.apache.org/r

Re: SAMZA-14

2013-09-04 Thread Neha Narkhede
Jay, Was this meant for the samza dev list ? :) Thanks, Neha On Wed, Sep 4, 2013 at 1:30 PM, Jay Kreps wrote: > I have the QA torture jobs running. And all the various killings now work > as expected (kafka, yarn rm, yarn nm, samza am, samza containers). One > thing I didn't figure out was h

Re: SAMZA-14

2013-09-04 Thread Jay Kreps
Yup. -Jay On Wed, Sep 4, 2013 at 1:44 PM, Neha Narkhede wrote: > Jay, > > Was this meant for the samza dev list ? :) > > Thanks, > Neha > > > On Wed, Sep 4, 2013 at 1:30 PM, Jay Kreps wrote: > > > I have the QA torture jobs running. And all the various killings now work > > as expected (kafka

[jira] [Commented] (KAFKA-998) Producer should not retry on non-recoverable error codes

2013-09-04 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13758450#comment-13758450 ] Joel Koshy commented on KAFKA-998: -- Apologies for the late review. Couple of comments: * I

Re: Review Request 13908: Initial patch KAFKA-1012

2013-09-04 Thread Neha Narkhede
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/13908/#review25904 --- core/src/main/scala/kafka/common/ErrorMapping.scala

[jira] [Created] (KAFKA-1042) Fix segment flush logic

2013-09-04 Thread Joris Van Remoortere (JIRA)
Joris Van Remoortere created KAFKA-1042: --- Summary: Fix segment flush logic Key: KAFKA-1042 URL: https://issues.apache.org/jira/browse/KAFKA-1042 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-1042) Fix segment flush logic

2013-09-04 Thread Joris Van Remoortere (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joris Van Remoortere updated KAFKA-1042: Attachment: flush_segment_fix-v1.patch > Fix segment flush logic >

[jira] [Commented] (KAFKA-1035) Add message-send-max-retries and retry-backoff-ms options to console producer

2013-09-04 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13758616#comment-13758616 ] Guozhang Wang commented on KAFKA-1035: -- Sorry but I am not one of the committers.. Ca

[jira] [Commented] (KAFKA-1011) Decompression and re-compression on MirrorMaker could result in messages being dropped in the pipeline

2013-09-04 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13758620#comment-13758620 ] Guozhang Wang commented on KAFKA-1011: -- Thank Jun, you are right. The message metadat

[jira] [Commented] (KAFKA-998) Producer should not retry on non-recoverable error codes

2013-09-04 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13758659#comment-13758659 ] Guozhang Wang commented on KAFKA-998: - Thanks for the patch Joel. Do you mean rebase on

[jira] [Commented] (KAFKA-1039) kafka return acks but not logging while sending messages with compression

2013-09-04 Thread Xiang chao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13758717#comment-13758717 ] Xiang chao commented on KAFKA-1039: --- It seems they are the same problem.

[jira] [Commented] (KAFKA-1012) Implement an Offset Manager and hook offset requests to it

2013-09-04 Thread Tejas Patil (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13758830#comment-13758830 ] Tejas Patil commented on KAFKA-1012: Sriram and Neha had concerns about the OffsetMana