[jira] [Updated] (KAFKA-1339) Time based offset retrieval seems broken

[ https://issues.apache.org/jira/browse/KAFKA-1339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Frank Varnavas updated KAFKA-1339: -- Affects Version/s: (was: 0.8.1) 0.8.0 > Time based offset retrieval

[jira] [Commented] (KAFKA-1324) Debian packaging

[ https://issues.apache.org/jira/browse/KAFKA-1324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13947880#comment-13947880 ] Joe Stein commented on KAFKA-1324: -- Hi David, I got a failure when running releaseDeb the

[jira] [Updated] (KAFKA-1324) Debian packaging

[ https://issues.apache.org/jira/browse/KAFKA-1324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1324: - Fix Version/s: 0.8.2 > Debian packaging > > > Key: KAFKA-1324 >

Re: Review Request 19626: Patch for KAFKA-1323

> On March 26, 2014, 12:55 a.m., Neha Narkhede wrote: > > My guess is that we may have to review and make a similar change in the > > following places - > > 1. LogManager.checkpointRecoveryPointOffsets() > > 2. LogManager.nextLogDir() > > > > The unit test in ReplicaManagerTest cover checkpoint

Re: Review Request 19577: Patch for KAFKA-1317

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19577/ --- (Updated March 26, 2014, 4:48 p.m.) Review request for kafka. Bugs: KAFKA-131

[jira] [Updated] (KAFKA-1317) KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly related to TopicDeletionManager or MetricsMeter state

[ https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timothy Chen updated KAFKA-1317: Attachment: KAFKA-1317_2014-03-26_09:48:03.patch > KafkaServer 0.8.1 not responding to .shutdown()

[jira] [Commented] (KAFKA-1317) KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly related to TopicDeletionManager or MetricsMeter state

[ https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13948082#comment-13948082 ] Timothy Chen commented on KAFKA-1317: - Updated reviewboard https://reviews.apache.org/

[jira] [Created] (KAFKA-1340) hadoop-consumer not working with hadoop 2.2.0

Marcelo Valle Avila created KAFKA-1340: -- Summary: hadoop-consumer not working with hadoop 2.2.0 Key: KAFKA-1340 URL: https://issues.apache.org/jira/browse/KAFKA-1340 Project: Kafka Issue

Re: Review Request 19388: Patch for KAFKA-1251

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19388/#review38570 --- I ran ProducerPerformance on a local broker and saw one problem. A p

[jira] [Commented] (KAFKA-1028) per topic configuration of preference for consistency over availability

[ https://issues.apache.org/jira/browse/KAFKA-1028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13948159#comment-13948159 ] Andrew Olson commented on KAFKA-1028: - The tests included with the patch do verify con

[jira] [Updated] (KAFKA-1251) Add metrics to the producer

[ https://issues.apache.org/jira/browse/KAFKA-1251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1251: - Attachment: metrics.png > Add metrics to the producer > --- > >

[jira] [Commented] (KAFKA-1251) Add metrics to the producer

[ https://issues.apache.org/jira/browse/KAFKA-1251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13948165#comment-13948165 ] Neha Narkhede commented on KAFKA-1251: -- Thanks for the latest patch, Jay. Overall met

[jira] [Commented] (KAFKA-1028) per topic configuration of preference for consistency over availability

[ https://issues.apache.org/jira/browse/KAFKA-1028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13948166#comment-13948166 ] Neha Narkhede commented on KAFKA-1028: -- Thanks [~noslowerdna], appreciate your contri

Review Request 19690: Patch for KAFKA-1341

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

[jira] [Created] (KAFKA-1341) Client Selector doesn't check connection id properly

Timothy Chen created KAFKA-1341: --- Summary: Client Selector doesn't check connection id properly Key: KAFKA-1341 URL: https://issues.apache.org/jira/browse/KAFKA-1341 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-1341) Client Selector doesn't check connection id properly

[ https://issues.apache.org/jira/browse/KAFKA-1341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13948219#comment-13948219 ] Timothy Chen commented on KAFKA-1341: - Created reviewboard https://reviews.apache.org/

[jira] [Updated] (KAFKA-1341) Client Selector doesn't check connection id properly

[ https://issues.apache.org/jira/browse/KAFKA-1341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timothy Chen updated KAFKA-1341: Attachment: KAFKA-1341.patch > Client Selector doesn't check connection id properly > -

Re: Review Request 18299: Fix KAFKA-1253

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/18299/ --- (Updated March 26, 2014, 5:59 p.m.) Review request for kafka. Bugs: KAFKA-125

[jira] [Updated] (KAFKA-1253) Implement compression in new producer

[ https://issues.apache.org/jira/browse/KAFKA-1253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1253: - Attachment: KAFKA-1253_2014-03-26_10:59:00.patch > Implement compression in new producer > --

[jira] [Commented] (KAFKA-1253) Implement compression in new producer

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

[jira] [Updated] (KAFKA-1317) KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly related to TopicDeletionManager or MetricsMeter state

[ https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timothy Chen updated KAFKA-1317: Attachment: KAFKA-1317_2014-03-26_11:30:57.patch > KafkaServer 0.8.1 not responding to .shutdown()

[jira] [Commented] (KAFKA-1317) KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly related to TopicDeletionManager or MetricsMeter state

[ https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13948273#comment-13948273 ] Timothy Chen commented on KAFKA-1317: - Updated reviewboard https://reviews.apache.org/

Re: Review Request 19577: Patch for KAFKA-1317

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19577/ --- (Updated March 26, 2014, 6:31 p.m.) Review request for kafka. Bugs: KAFKA-131

[jira] [Commented] (KAFKA-1251) Add metrics to the producer

[ https://issues.apache.org/jira/browse/KAFKA-1251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13948285#comment-13948285 ] Jay Kreps commented on KAFKA-1251: -- Yes, I hadn't really considered this a bug. Those are

Review Request 19696: Patch for KAFKA-1317

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

[jira] [Updated] (KAFKA-1317) KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly related to TopicDeletionManager or MetricsMeter state

[ https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timothy Chen updated KAFKA-1317: Attachment: KAFKA-1317.patch > KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly re

[jira] [Commented] (KAFKA-1317) KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly related to TopicDeletionManager or MetricsMeter state

[ https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13948316#comment-13948316 ] Timothy Chen commented on KAFKA-1317: - Created reviewboard https://reviews.apache.org/

Re: Review Request 19696: Patch for KAFKA-1317

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19696/ --- (Updated March 26, 2014, 6:59 p.m.) Review request for kafka. Bugs: KAFKA-131

Re: Review Request 19696: Patch for KAFKA-1317

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19696/#review38648 --- Tim, I get the following conflict when I try to apply this patch to

Re: Review Request 19696: Patch for KAFKA-1317

> On March 26, 2014, 7:16 p.m., Neha Narkhede wrote: > > Tim, > > > > I get the following conflict when I try to apply this patch to the 0.8.1 > > branch - > > > > nnarkhed-mn1:kafka-git-idea nnarkhed$ patch -p1 -i > > ~/Projects/kafka-patches/kafka-1317-march26.patch > > patching file core/

[jira] [Commented] (KAFKA-1047) Typo in Documentation for Kafka, change "on" to "one"

[ https://issues.apache.org/jira/browse/KAFKA-1047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13948483#comment-13948483 ] James Stanier commented on KAFKA-1047: -- It looks like this has been fixed in the docu

[jira] [Commented] (KAFKA-1048) Type in Documentation for Kafka - server to serve

[ https://issues.apache.org/jira/browse/KAFKA-1048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13948487#comment-13948487 ] James Stanier commented on KAFKA-1048: -- Like KAFKA-1047, this has also been fixed in

Re: Review Request 19577: Patch for KAFKA-1317

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19577/#review38662 --- Overall, almost ready for checkin. Few comments before we checkin -

Re: Review Request 19577: Patch for KAFKA-1317

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19577/ --- (Updated March 26, 2014, 10:05 p.m.) Review request for kafka. Bugs: KAFKA-13

Re: Help in setting up Kafka cluster

Hi Roy, I wonder if you were able to start the broker following the steps here: http://kafka.apache.org/documentation.html#quickstart That page also shows you how to create a topic and send/consume messages using the console producer/consumer. Let us know if you run into any problems, Tim On

Re: Review Request 19577: Patch for KAFKA-1317

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19577/ --- (Updated March 26, 2014, 10:09 p.m.) Review request for kafka. Bugs: KAFKA-13

[jira] [Updated] (KAFKA-1317) KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly related to TopicDeletionManager or MetricsMeter state

[ https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timothy Chen updated KAFKA-1317: Attachment: KAFKA-1317_2014-03-26_15:09:48.patch > KafkaServer 0.8.1 not responding to .shutdown()

[jira] [Commented] (KAFKA-1317) KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly related to TopicDeletionManager or MetricsMeter state

[ https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13948546#comment-13948546 ] Timothy Chen commented on KAFKA-1317: - Updated reviewboard https://reviews.apache.org/

Re: Review Request 19696: Patch for KAFKA-1317

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19696/ --- (Updated March 26, 2014, 10:19 p.m.) Review request for kafka. Bugs: KAFKA-13

[jira] [Updated] (KAFKA-1317) KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly related to TopicDeletionManager or MetricsMeter state

[ https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timothy Chen updated KAFKA-1317: Attachment: KAFKA-1317_2014-03-26_15:18:52.patch > KafkaServer 0.8.1 not responding to .shutdown()

[jira] [Commented] (KAFKA-1317) KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly related to TopicDeletionManager or MetricsMeter state

[ https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13948559#comment-13948559 ] Timothy Chen commented on KAFKA-1317: - Updated reviewboard https://reviews.apache.org/

Re: Review Request 19577: Patch for KAFKA-1317

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19577/#review38666 --- Ship it! Ship It! - Neha Narkhede On March 26, 2014, 10:09 p.m.,

Re: Review Request 19626: Patch for KAFKA-1323

> On March 26, 2014, 12:55 a.m., Neha Narkhede wrote: > > My guess is that we may have to review and make a similar change in the > > following places - > > 1. LogManager.checkpointRecoveryPointOffsets() > > 2. LogManager.nextLogDir() > > > > The unit test in ReplicaManagerTest cover checkpoint

Re: Review Request 19696: Patch for KAFKA-1317

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19696/#review38670 --- When I applied this patch to trunk, I started seeing unit test failu

[jira] [Resolved] (KAFKA-1048) Type in Documentation for Kafka - server to serve

[ https://issues.apache.org/jira/browse/KAFKA-1048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1048. -- Resolution: Fixed > Type in Documentation for Kafka - server to serve > ---

[jira] [Closed] (KAFKA-1047) Typo in Documentation for Kafka, change "on" to "one"

[ https://issues.apache.org/jira/browse/KAFKA-1047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-1047. > Typo in Documentation for Kafka, change "on" to "one" > -

[jira] [Resolved] (KAFKA-1047) Typo in Documentation for Kafka, change "on" to "one"

[ https://issues.apache.org/jira/browse/KAFKA-1047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1047. -- Resolution: Fixed > Typo in Documentation for Kafka, change "on" to "one" > ---

[jira] [Closed] (KAFKA-1048) Type in Documentation for Kafka - server to serve

[ https://issues.apache.org/jira/browse/KAFKA-1048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-1048. > Type in Documentation for Kafka - server to serve > -

Re: Review Request 19696: Patch for KAFKA-1317

> On March 26, 2014, 10:59 p.m., Neha Narkhede wrote: > > When I applied this patch to trunk, I started seeing unit test failures. In > > my last test run, kafka.log4j.KafkaLog4jAppenderTest fails. Before this, > > I've never seen unit test failures, so I wonder if this patch is causing > > th

[jira] [Created] (KAFKA-1342) Slow controlled shutdowns can result in stale shutdown requests

Joel Koshy created KAFKA-1342: - Summary: Slow controlled shutdowns can result in stale shutdown requests Key: KAFKA-1342 URL: https://issues.apache.org/jira/browse/KAFKA-1342 Project: Kafka Issu

Re: Review Request 18299: Fix KAFKA-1253

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/18299/#review38694 --- Ship it! +1. config/log4j.properties

Help in setting up Kafka cluster

Hi, First time I am trying to setup new kafka cluster. I have tried sudo cluster with cli based kafka producer and consumer. Having difficulties with setting up log aggregation kafka producer and consumer. I would appreciate if anyone can help me in this. - roy

[jira] [Resolved] (KAFKA-1253) Implement compression in new producer

[ https://issues.apache.org/jira/browse/KAFKA-1253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1253. -- Resolution: Fixed Thanks for the patches and your patience [~guozhang]! Committed to trunk > I