[jira] [Commented] (KAFKA-1591) Clean-up Unnecessary stack trace in error/warn logs

[ https://issues.apache.org/jira/browse/KAFKA-1591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14120959#comment-14120959 ] Abhishek Sharma commented on KAFKA-1591: Another INFO entry makes logs dirty is -

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14120944#comment-14120944 ] Jun Rao commented on KAFKA-1555: Gwen, Thanks for helping out. I think we can take the ap

Re: Review Request 25155: Fix KAFKA-1616

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25155/#review52276 --- A few more minor comments below. core/src/main/scala/kafka/server/

[DISCUSS] 0.8.2 release branch, "unofficial" release candidates(s), 0.8.1.2 release

+1 on a 0.8.1.2 release as described. I manually applied patches to cobble together a working gradle build for kafka for scala 2.11, but would really appreciate an official release — i.e. 0.8.1.2, as we also have other dependent libraries we use as well (e.g. akka-kafka) that would be much eas

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14120820#comment-14120820 ] Joe Stein commented on KAFKA-1555: -- +1 around the min.isr approach I would be happy to

[jira] [Assigned] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein reassigned KAFKA-1555: Assignee: Gwen Shapira (was: Neha Narkhede) > provide strong consistency with reasonable availabil

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14120815#comment-14120815 ] Gwen Shapira commented on KAFKA-1555: - If there's a consensus (or even a lazy consensu

[DISCUSS] 0.8.2 release branch, "unofficial" release candidates(s), 0.8.1.2 release

Hey, I wanted to take a quick pulse to see if we are getting closer to a branch for 0.8.2. 1) There still seems to be a lot of open issues https://issues.apache.org/jira/browse/KAFKA/fixforversion/12326167/?selectedTab=com.atlassian.jira.jira-projects-plugin:version-issues-panel and our 30 day sum

[jira] [Updated] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1555: - Fix Version/s: 0.8.2 > provide strong consistency with reasonable availability > -

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14120810#comment-14120810 ] Joe Stein commented on KAFKA-1555: -- Where have we ended up with this? Do we have an agree

Re: Review Request 24676: Fix KAFKA-1583

> On Sept. 3, 2014, 6:23 p.m., Jun Rao wrote: > > Looks good. I only have the following minor comments. Thanks Jun. If there is no more comments for now I will wait for KAFKA-1616 to be checked in first, and then do the rebase and the class / function renaming (which will make the diff file qu

Re: Review Request 24676: Fix KAFKA-1583

> On Sept. 3, 2014, 6:23 p.m., Jun Rao wrote: > > core/src/main/scala/kafka/server/DelayedFetch.scala, line 100 > > > > > > Should we log topicAndPartition as well? fetchMetadata includes the fetchPartitionStatus, tha

[jira] [Commented] (KAFKA-686) 0.8 Kafka broker should give a better error message when running against 0.7 zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14120664#comment-14120664 ] Guozhang Wang commented on KAFKA-686: - Thanks [~phargett] and [~viktortnk] for your pat

Java Custom SLF4J Implementation and Kafka Lib Logs

Hi Dev, We are in process of upgrading the from 0.8.1 to trunk. I have noticed that Java New Kafka Producer Lib uses SLF4J api to log kafka logs. We have our own library which send all LOGGER.logXXX("MSG")" using the Kafka Lib so what is best way avoid it. One of way is to avoid all producer s

[jira] [Commented] (KAFKA-1591) Clean-up Unnecessary stack trace in error/warn logs

[ https://issues.apache.org/jira/browse/KAFKA-1591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14120435#comment-14120435 ] Guozhang Wang commented on KAFKA-1591: -- Thanks for the patch. Could you go through th

Re: Review Request 25136: Patch for KAFKA-1610

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25136/#review52234 --- Ship it! Ship It! - Guozhang Wang On Sept. 3, 2014, 6:27 p.m., M

[jira] [Updated] (KAFKA-1616) Purgatory Size and Num.Delayed.Request metrics are incorrect

[ https://issues.apache.org/jira/browse/KAFKA-1616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1616: - Attachment: KAFKA-1616_2014-09-03_12:53:09.patch > Purgatory Size and Num.Delayed.Request metrics

[jira] [Commented] (KAFKA-1616) Purgatory Size and Num.Delayed.Request metrics are incorrect

[ https://issues.apache.org/jira/browse/KAFKA-1616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14120328#comment-14120328 ] Guozhang Wang commented on KAFKA-1616: -- Updated reviewboard https://reviews.apache.or

Re: Review Request 25155: Fix KAFKA-1616

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25155/ --- (Updated Sept. 3, 2014, 7:52 p.m.) Review request for kafka. Bugs: KAFKA-1616

Re: Review Request 25155: Fix KAFKA-1616

> On Sept. 2, 2014, 4:51 p.m., Jun Rao wrote: > > core/src/main/scala/kafka/server/RequestPurgatory.scala, lines 268-270 > > > > > > I thought that we only want to call purgeSatisfied if delayed.size >= > > purgeIntve

Re: Review Request 24676: Fix KAFKA-1583

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24676/#review52092 --- Looks good. I only have the following minor comments. core/src/mai

[jira] [Updated] (KAFKA-1610) Local modifications to collections generated from mapValues will be lost

[ https://issues.apache.org/jira/browse/KAFKA-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat updated KAFKA-1610: --- Attachment: KAFKA-1610_2014-09-03_11:27:50.patch > Local modifications to collections generate

[jira] [Commented] (KAFKA-1610) Local modifications to collections generated from mapValues will be lost

[ https://issues.apache.org/jira/browse/KAFKA-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14120214#comment-14120214 ] Mayuresh Gharat commented on KAFKA-1610: Updated reviewboard https://reviews.apach

Re: Review Request 25136: Patch for KAFKA-1610

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25136/ --- (Updated Sept. 3, 2014, 6:27 p.m.) Review request for kafka. Bugs: KAFKA-1610

Subscription

Subscription -- Massimiliano Tomassi web: http://about.me/maxtomassi e-mail: max.toma...@gmail.com mobile: +447751193667

[jira] [Commented] (KAFKA-1382) Update zkVersion on partition state update failures

[ https://issues.apache.org/jira/browse/KAFKA-1382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14120028#comment-14120028 ] Noah Yetter commented on KAFKA-1382: Is it possible to apply this patch to 0.8.1.1? O

Re: How to debug unit test in Eclipse

my question is - ~ Is there any eclipse plugin required for execution like gradle plugin? ~ Unit test cases is needed to be run as junit or scala unit? Please share some starting pointer related to it. Thanks On Wed, Sep 3, 2014 at 3:58 AM, Neha Narkhede wrote: > Yes, it is possible. Looks l