[jira] [Created] (KAFKA-1056) Evenly Distribute Intervals in OffsetIndex

Guozhang Wang created KAFKA-1056: Summary: Evenly Distribute Intervals in OffsetIndex Key: KAFKA-1056 URL: https://issues.apache.org/jira/browse/KAFKA-1056 Project: Kafka Issue Type: Improvem

[jira] [Created] (KAFKA-1055) BrokerTopicStats is updated before checking for MessageSizeTooLarge

Guozhang Wang created KAFKA-1055: Summary: BrokerTopicStats is updated before checking for MessageSizeTooLarge Key: KAFKA-1055 URL: https://issues.apache.org/jira/browse/KAFKA-1055 Project: Kafka

Re: Review Request 14149: test summary

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/14149/#review26143 --- I did not see changes on AbstractFetcherManager/ConsumerFetcherManag

Re: [VOTE] Bylaws!

+1 On Fri, Sep 13, 2013 at 7:36 PM, Jun Rao wrote: > +1 > > Jun > > > On Fri, Sep 13, 2013 at 9:53 AM, Jay Kreps wrote: > > > It was pointed out to us that Apache projects should formalize their > > bylaws--basically how votes are done, who votes on what, and what the > > criteria are for voti

[jira] [Issue Comment Deleted] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Comment: was deleted (was: Created reviewboard https://reviews.apache.org/r/14161/ ) > Consu

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

[ https://issues.apache.org/jira/browse/KAFKA-1011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13768820#comment-13768820 ] Guozhang Wang commented on KAFKA-1011: -- Currently the main issue is the MessageAndMet

[jira] [Commented] (KAFKA-1053) Kafka patch review tool

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

[jira] [Updated] (KAFKA-1053) Kafka patch review tool

[ https://issues.apache.org/jira/browse/KAFKA-1053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1053: - Attachment: KAFKA-1053_2013-09-16_14:40:15.patch > Kafka patch review tool >

Re: Review Request 14091: Patch for KAFKA-1053

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/14091/ --- (Updated Sept. 16, 2013, 9:40 p.m.) Review request for kafka. Bugs: KAFKA-105

[jira] [Commented] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13768778#comment-13768778 ] Swapnil Ghike commented on KAFKA-1003: -- Created reviewboard https://reviews.apache.or

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: (was: KAFKA-1003.patch) > ConsumerFetcherManager should pass clientId as metr

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: KAFKA-1003.patch > ConsumerFetcherManager should pass clientId as metricsPrefix t

Review Request 14161: Patch for KAFKA-1003

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/14161/ --- Review request for kafka. Bugs: KAFKA-1003 https://issues.apache.org/jira/b

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: (was: KAFKA-1003.patch) > ConsumerFetcherManager should pass clientId as metr

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: (was: KAFKA-1003.patch) > ConsumerFetcherManager should pass clientId as metr

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: KAFKA-1003.patch > ConsumerFetcherManager should pass clientId as metricsPrefix t

[jira] [Commented] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13768770#comment-13768770 ] Swapnil Ghike commented on KAFKA-1003: -- Created reviewboard > Consu

[jira] [Commented] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13768771#comment-13768771 ] Swapnil Ghike commented on KAFKA-1003: -- Created reviewboard > Consu

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: (was: KAFKA-1003_2013-09-16_14:13:04.patch) > ConsumerFetcherManager should p

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: KAFKA-1003.patch > ConsumerFetcherManager should pass clientId as metricsPrefix t

[jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication

[ https://issues.apache.org/jira/browse/KAFKA-42?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-42: --- Attachment: (was: KAFKA-42.patch) > Support rebalancing the partitions with replication > -

[jira] [Commented] (KAFKA-42) Support rebalancing the partitions with replication

[ https://issues.apache.org/jira/browse/KAFKA-42?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13768747#comment-13768747 ] Swapnil Ghike commented on KAFKA-42: Created reviewboard > Support reb

[jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication

[ https://issues.apache.org/jira/browse/KAFKA-42?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-42: --- Attachment: KAFKA-42.patch > Support rebalancing the partitions with replication >

[jira] [Issue Comment Deleted] (KAFKA-42) Support rebalancing the partitions with replication

[ https://issues.apache.org/jira/browse/KAFKA-42?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-42: --- Comment: was deleted (was: Created reviewboard ) > Support rebalancing the partitions with replica

[jira] [Commented] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13768768#comment-13768768 ] Swapnil Ghike commented on KAFKA-1003: -- Updated reviewboard > Consu

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: KAFKA-1003_2013-09-16_14:13:04.patch > ConsumerFetcherManager should pass clientI

[jira] [Comment Edited] (KAFKA-1053) Kafka patch review tool

[ https://issues.apache.org/jira/browse/KAFKA-1053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13768756#comment-13768756 ] Swapnil Ghike edited comment on KAFKA-1053 at 9/16/13 9:02 PM: -

[jira] [Commented] (KAFKA-1053) Kafka patch review tool

[ https://issues.apache.org/jira/browse/KAFKA-1053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13768756#comment-13768756 ] Swapnil Ghike commented on KAFKA-1053: -- Saw new error on RHEL when I tried 'python ka

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

[ https://issues.apache.org/jira/browse/KAFKA-1011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13768521#comment-13768521 ] Guozhang Wang commented on KAFKA-1011: -- Besides batching, two other critical function

[jira] Subscription: outstanding kafka patches

Issue Subscription Filter: outstanding kafka patches (68 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-1053 Kafka patch review tool https://issues.apache.org/jira/browse/KAFKA-1053 KAFKA-1042 Fix segment flush logic

[jira] [Commented] (KAFKA-1054) Elimiate Compilation Warnings for 0.8 Final Release

[ https://issues.apache.org/jira/browse/KAFKA-1054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13768632#comment-13768632 ] Guozhang Wang commented on KAFKA-1054: -- After KAFKA-1046 we still have all those warn

[jira] [Commented] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13768494#comment-13768494 ] Swapnil Ghike commented on KAFKA-1003: -- Created reviewboard > Consu

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: KAFKA-1003.patch > ConsumerFetcherManager should pass clientId as metricsPrefix t

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: KAFKA-1003.patch > ConsumerFetcherManager should pass clientId as metricsPrefix t

[jira] [Issue Comment Deleted] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Comment: was deleted (was: Created reviewboard https://reviews.apache.org/r/14149/ ) > Consu

Review Request 14149: test summary

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/14149/ --- Review request for kafka. Bugs: KAFKA-1003 https://issues.apache.org/jira/b

[jira] [Commented] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13768493#comment-13768493 ] Swapnil Ghike commented on KAFKA-1003: -- Created reviewboard > Consu

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: KAFKA-1003.patch > ConsumerFetcherManager should pass clientId as metricsPrefix t

[jira] [Commented] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13768495#comment-13768495 ] Swapnil Ghike commented on KAFKA-1003: -- Created reviewboard > Consu

[jira] [Commented] (KAFKA-1053) Kafka patch review tool

[ https://issues.apache.org/jira/browse/KAFKA-1053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13768505#comment-13768505 ] Neha Narkhede commented on KAFKA-1053: -- Cool! Swapnil, could you help me add a FAQ to

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: (was: KAFKA-1003.patch) > ConsumerFetcherManager should pass clientId as metr

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: (was: KAFKA-1003.patch) > ConsumerFetcherManager should pass clientId as metr

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: (was: KAFKA-1003.patch) > ConsumerFetcherManager should pass clientId as metr

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: (was: KAFKA-1003.patch) > ConsumerFetcherManager should pass clientId as metr

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: (was: KAFKA-1003.patch) > ConsumerFetcherManager should pass clientId as metr

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: (was: KAFKA-1003.patch) > ConsumerFetcherManager should pass clientId as metr

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: (was: KAFKA-1003.patch) > ConsumerFetcherManager should pass clientId as metr

[jira] [Commented] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13768496#comment-13768496 ] Swapnil Ghike commented on KAFKA-1003: -- Created reviewboard https://reviews.apache.or

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: (was: KAFKA-1003.patch) > ConsumerFetcherManager should pass clientId as metr

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: (was: KAFKA-1003.patch) > ConsumerFetcherManager should pass clientId as metr

Re: Review Request 14091: Patch for KAFKA-1053

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/14091/#review26141 --- Ship it! Ship It! - Swapnil Ghike On Sept. 16, 2013, 3:28 a.m.,

Re: Review Request 14091: Patch for KAFKA-1053

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/14091/#review26140 --- kafka-patch-review.py

[jira] [Commented] (KAFKA-1053) Kafka patch review tool

[ https://issues.apache.org/jira/browse/KAFKA-1053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13768499#comment-13768499 ] Swapnil Ghike commented on KAFKA-1053: -- After installing arg_parse and using origin/0

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: KAFKA-1003.patch > ConsumerFetcherManager should pass clientId as metricsPrefix t

[jira] [Commented] (KAFKA-1053) Kafka patch review tool

[ https://issues.apache.org/jira/browse/KAFKA-1053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13768452#comment-13768452 ] Neha Narkhede commented on KAFKA-1053: -- Updated the Setup section of the wiki with in

Re: [jira] [Commented] (KAFKA-1053) Kafka patch review tool

For 1. I ran into this also and I was using Python 2.6.6, so I downloaded argparse and then it works: https://pypi.python.org/pypi/argparse Guozhang On Sun, Sep 15, 2013 at 6:04 PM, Neha Narkhede (JIRA) wrote: > > [ > https://issues.apache.org/jira/browse/KAFKA-1053?page=com.atlassian.jira

Re: Query : failed due to Leader not local for partition

Hi Anuj, Could you describe how to reproduce this? And will this exception result in message failed to send in the end? I still think this is transient, as the producer retries in the future and as the leader be elected, the messages should be sent eventually. Guozhang On Mon, Sep 16, 2013 at 7

Re: Query : failed due to Leader not local for partition

Anuj, If you look at Partition.makeLeader(), leaderReplicaOpt gets updated to the latest leader. As Guozhang pointed out, this error should be transient. Thanks, Neha On Sep 16, 2013 5:22 AM, "Anuj Mehta" wrote: > Hi Guozhang > > Thanks for your reply. The problem is not transient in my case.

Re: Query : failed due to Leader not local for partition

Hi Guozhang Thanks for your reply. The problem is not transient in my case. I tried debugging the issue and find problem in following code snippet (please correct me if I am wrong) As part of code for handling ProducerRequest (from KafkaApis) following code is executed val partitionOpt = replic

Kafka security

https://cwiki.apache.org/confluence/display/KAFKA/Security we'd like to help with this - who is best to contact? Joe