[jira] [Commented] (KAFKA-735) Add looping and JSON output for ConsumerOffsetChecker

[ https://issues.apache.org/jira/browse/KAFKA-735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13670061#comment-13670061 ] Jun Rao commented on KAFKA-735: --- Sorry for the late review. This probably should be fixed in

[jira] [Updated] (KAFKA-733) Fat jar option for build, or override for ivy cache location

[ https://issues.apache.org/jira/browse/KAFKA-733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-733: -- Resolution: Duplicate Fix Version/s: 0.8 Status: Resolved (was: Patch Available) This is alre

[jira] [Commented] (KAFKA-852) Remove clientId from OffsetFetchResponse and OffsetCommitResponse

[ https://issues.apache.org/jira/browse/KAFKA-852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13670055#comment-13670055 ] Jun Rao commented on KAFKA-852: --- Sorry for the late review. The patch no longer applies to tr

[jira] [Updated] (KAFKA-856) Correlation id for OffsetFetch request (#2) always responds with 0

[ https://issues.apache.org/jira/browse/KAFKA-856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-856: -- Resolution: Fixed Fix Version/s: 0.8 Status: Resolved (was: Patch Available) Thanks for the p

[jira] [Updated] (KAFKA-897) NullPointerException in ConsoleConsumer

[ https://issues.apache.org/jira/browse/KAFKA-897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-897: -- Resolution: Fixed Fix Version/s: 0.8.1 Status: Resolved (was: Patch Available) Thanks for the

[jira] [Commented] (KAFKA-881) Kafka broker not respecting log.roll.hours

[ https://issues.apache.org/jira/browse/KAFKA-881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13670028#comment-13670028 ] Jun Rao commented on KAFKA-881: --- Sorry for the delay. I can't apply the patch to the 0.7 bran

[jira] [Updated] (KAFKA-259) Give better error message when trying to run shell scripts without having built/downloaded the jars yet

[ https://issues.apache.org/jira/browse/KAFKA-259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-259: -- Resolution: Fixed Fix Version/s: 0.8 Status: Resolved (was: Patch Available) Thanks for patch

Re: Contribution info

You just need to create an Apache jira account so that you can attach patches. Thanks, Jun On Wed, May 29, 2013 at 11:21 AM, Krishna Kiran M wrote: > Hi ,Do I need to register as any member to be able to contribute as > Developer for this project" > > Regards, > Krishna > 214-326-8816 >

[jira] [Updated] (KAFKA-899) LeaderNotAvailableException the first time a new message for a partition is processed.

[ https://issues.apache.org/jira/browse/KAFKA-899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-899: -- Attachment: kafka-899_v3.patch Thanks for the review. Attach patch v3 that addresses the above issue. Changed t

[jira] [Updated] (KAFKA-259) Give better error message when trying to run shell scripts without having built/downloaded the jars yet

[ https://issues.apache.org/jira/browse/KAFKA-259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashwanth Fernando updated KAFKA-259: Attachment: KAFKA-259-v2.patch > Give better error message when trying to run shell scri

[jira] [Commented] (KAFKA-259) Give better error message when trying to run shell scripts without having built/downloaded the jars yet

[ https://issues.apache.org/jira/browse/KAFKA-259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13669862#comment-13669862 ] Ashwanth Fernando commented on KAFKA-259: - [~junrao] - I executed the simple contri

[jira] [Updated] (KAFKA-921) Expose max lag mbean for consumers and replica fetchers

[ https://issues.apache.org/jira/browse/KAFKA-921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy updated KAFKA-921: - Attachment: KAFKA-921-v2.patch Yes - I think that would be better. Moved it to AbstractFetcherManager. So

Contribution info

Hi ,Do I need to register as any member to be able to contribute as Developer for this project" Regards, Krishna 214-326-8816

[jira] [Commented] (KAFKA-917) Expose zk.session.timeout.ms in console consumer

[ https://issues.apache.org/jira/browse/KAFKA-917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13669450#comment-13669450 ] Neha Narkhede commented on KAFKA-917: - Please can you attach a patch for 0.7 branch ?

[jira] [Closed] (KAFKA-919) Disabling of auto commit is ignored during consumer group rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-919. --- > Disabling of auto commit is ignored during consumer group rebalancing >

[jira] [Created] (KAFKA-926) Error in consumer when the leader for some partitions is failing over to another replica.

BalajiSeshadri created KAFKA-926: Summary: Error in consumer when the leader for some partitions is failing over to another replica. Key: KAFKA-926 URL: https://issues.apache.org/jira/browse/KAFKA-926

[jira] [Commented] (KAFKA-926) Error in consumer when the leader for some partitions is failing over to another replica.

[ https://issues.apache.org/jira/browse/KAFKA-926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13669448#comment-13669448 ] BalajiSeshadri commented on KAFKA-926: -- Orginally this was part of KAFKA-816

[jira] [Commented] (KAFKA-649) Cleanup log4j logging

[ https://issues.apache.org/jira/browse/KAFKA-649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13669440#comment-13669440 ] Jun Rao commented on KAFKA-649: --- Thanks for the review. Addressed the comment and committed t

[jira] [Commented] (KAFKA-816) Reduce noise in Kafka server logs due to NotLeaderForPartitionException

[ https://issues.apache.org/jira/browse/KAFKA-816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13669434#comment-13669434 ] Neha Narkhede commented on KAFKA-816: - Balaji, That fix was to reduce the noise in th

[jira] [Updated] (KAFKA-900) ClosedByInterruptException when high-level consumer shutdown normally

[ https://issues.apache.org/jira/browse/KAFKA-900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-900: -- Resolution: Fixed Fix Version/s: 0.8 Status: Resolved (was: Patch Available) Thanks for the r

[jira] [Commented] (KAFKA-649) Cleanup log4j logging

[ https://issues.apache.org/jira/browse/KAFKA-649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13669433#comment-13669433 ] Neha Narkhede commented on KAFKA-649: - Actually, there is another error message that ne

[jira] [Commented] (KAFKA-259) Give better error message when trying to run shell scripts without having built/downloaded the jars yet

[ https://issues.apache.org/jira/browse/KAFKA-259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13669425#comment-13669425 ] Jun Rao commented on KAFKA-259: --- Thanks for the patch. It doesn't apply to 0.8 though. Could

[jira] [Commented] (KAFKA-649) Cleanup log4j logging

[ https://issues.apache.org/jira/browse/KAFKA-649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13669426#comment-13669426 ] Neha Narkhede commented on KAFKA-649: - +1. Just one comment - KafkaApis: Can we please

Re: KAFKA-259

Ashwanth, Thanks for the patch. Commented on the jira. Jun On Tue, May 28, 2013 at 5:51 PM, Ashwanth Fernando < aferna...@walmartlabs.com> wrote: > Hi, > I have submitted a patch for KAFKA-259 and its been approved by legal. Can > you please go ahead and verify it and let me know how to procee

[jira] [Commented] (KAFKA-915) System Test - Mirror Maker testcase_5001 failed

[ https://issues.apache.org/jira/browse/KAFKA-915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13669421#comment-13669421 ] Neha Narkhede commented on KAFKA-915: - Joel, could you take a quick look ?

[jira] [Updated] (KAFKA-915) System Test - Mirror Maker testcase_5001 failed

[ https://issues.apache.org/jira/browse/KAFKA-915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-915: Assignee: Joel Koshy > System Test - Mirror Maker testcase_5001 failed > ---

[jira] [Commented] (KAFKA-923) Improve controller failover latency

[ https://issues.apache.org/jira/browse/KAFKA-923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13669417#comment-13669417 ] Jun Rao commented on KAFKA-923: --- Thanks for patch v2. Looks good. +1. > Impr

[jira] [Commented] (KAFKA-900) ClosedByInterruptException when high-level consumer shutdown normally

[ https://issues.apache.org/jira/browse/KAFKA-900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13669414#comment-13669414 ] Neha Narkhede commented on KAFKA-900: - +1, thanks for the patch! > Clo

[jira] [Commented] (KAFKA-922) System Test - set retry.backoff.ms=300 to testcase_0119

[ https://issues.apache.org/jira/browse/KAFKA-922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13669407#comment-13669407 ] Neha Narkhede commented on KAFKA-922: - +1, thanks John! > System Test

[jira] [Commented] (KAFKA-899) LeaderNotAvailableException the first time a new message for a partition is processed.

[ https://issues.apache.org/jira/browse/KAFKA-899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13669404#comment-13669404 ] Neha Narkhede commented on KAFKA-899: - Thanks for the patch! 1. Another place where we

[jira] [Updated] (KAFKA-923) Improve controller failover latency

[ https://issues.apache.org/jira/browse/KAFKA-923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-923: Attachment: kafka-923-v2.patch Thanks for the review. 1. Fixed it 2. Good point, removed the extra

[jira] [Updated] (KAFKA-899) LeaderNotAvailableException the first time a new message for a partition is processed.

[ https://issues.apache.org/jira/browse/KAFKA-899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-899: -- Attachment: kafka-899_v2.patch Attach patch v2 after the rebase. > LeaderNotAvailableException

[jira] [Updated] (KAFKA-925) Add optional partition key override in producer

[ https://issues.apache.org/jira/browse/KAFKA-925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-925: Attachment: KAFKA-925-v1.patch > Add optional partition key override in producer > -

[jira] [Created] (KAFKA-925) Add optional partition key override in producer

Jay Kreps created KAFKA-925: --- Summary: Add optional partition key override in producer Key: KAFKA-925 URL: https://issues.apache.org/jira/browse/KAFKA-925 Project: Kafka Issue Type: New Feature

[jira] [Commented] (KAFKA-923) Improve controller failover latency

[ https://issues.apache.org/jira/browse/KAFKA-923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13669340#comment-13669340 ] Jun Rao commented on KAFKA-923: --- Thanks for the patch. Looks good. Some minor comments: 1. R