[jira] [Commented] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204467#comment-14204467 ] Vladimir Tretyakov commented on KAFKA-1481: --- Hi [~jjkoshy] thx for your feedback

Re: Review Request 26474: KAFKA-1654 Provide a way to override server configuration from command line

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26474/ --- (Updated Nov. 10, 2014, 7:11 a.m.) Review request for kafka and Neha Narkhede.

[jira] [Updated] (KAFKA-1654) Provide a way to override server configuration from command line

[ https://issues.apache.org/jira/browse/KAFKA-1654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jarek Jarcec Cecho updated KAFKA-1654: -- Attachment: KAFKA-1654.patch > Provide a way to override server configuration from comma

[jira] [Commented] (KAFKA-1654) Provide a way to override server configuration from command line

[ https://issues.apache.org/jira/browse/KAFKA-1654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204442#comment-14204442 ] Jarek Jarcec Cecho commented on KAFKA-1654: --- Thank you for your additional feedb

Jenkins build is back to normal : Kafka-trunk #326

See

[jira] [Commented] (KAFKA-1760) Implement new consumer client

[ https://issues.apache.org/jira/browse/KAFKA-1760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204354#comment-14204354 ] Jay Kreps commented on KAFKA-1760: -- I uploaded a very rough draft for this. It implements

[jira] [Updated] (KAFKA-1760) Implement new consumer client

[ https://issues.apache.org/jira/browse/KAFKA-1760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1760: - Attachment: KAFKA-1760.patch > Implement new consumer client > - > >

[jira] [Updated] (KAFKA-1760) Implement new consumer client

[ https://issues.apache.org/jira/browse/KAFKA-1760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1760: - Assignee: Jay Kreps Status: Patch Available (was: Open) > Implement new consumer client > -

[jira] [Commented] (KAFKA-1760) Implement new consumer client

[ https://issues.apache.org/jira/browse/KAFKA-1760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204341#comment-14204341 ] Jay Kreps commented on KAFKA-1760: -- Created reviewboard https://reviews.apache.org/r/2779

Review Request 27799: Draft consumer client

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

[jira] [Updated] (KAFKA-1760) Implement new consumer client

[ https://issues.apache.org/jira/browse/KAFKA-1760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1760: - Description: Implement a consumer client. > Implement new consumer client > -

[jira] [Created] (KAFKA-1760) Implement new consumer client

Jay Kreps created KAFKA-1760: Summary: Implement new consumer client Key: KAFKA-1760 URL: https://issues.apache.org/jira/browse/KAFKA-1760 Project: Kafka Issue Type: Sub-task Reporter

[jira] [Updated] (KAFKA-1739) Remove testComplexCompressDecompress in MessageCompressionTest

[ https://issues.apache.org/jira/browse/KAFKA-1739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1739: - Resolution: Fixed Fix Version/s: (was: 0.9.0) 0.8.3 Status

[jira] [Commented] (KAFKA-328) Write unit test for kafka server startup and shutdown API

[ https://issues.apache.org/jira/browse/KAFKA-328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204323#comment-14204323 ] Neha Narkhede commented on KAFKA-328: - Few review comments- 1. Can you please use inter

[jira] [Updated] (KAFKA-559) Garbage collect old consumer metadata entries

[ https://issues.apache.org/jira/browse/KAFKA-559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-559: Reviewer: Joel Koshy (was: Neha Narkhede) Reassigning to [~jjkoshy] since he reviewed previous versi

[jira] [Commented] (KAFKA-1654) Provide a way to override server configuration from command line

[ https://issues.apache.org/jira/browse/KAFKA-1654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204310#comment-14204310 ] Neha Narkhede commented on KAFKA-1654: -- Thanks for the updated patch. Here are my rev

[jira] [Commented] (KAFKA-1476) Get a list of consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204308#comment-14204308 ] Neha Narkhede commented on KAFKA-1476: -- [~balaji.sesha...@dish.com] Sorry for the lat

Re: Review Request 27693: Patch for KAFKA-1476

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/27693/#review60537 --- core/src/main/scala/kafka/tools/ConsumerCommand.scala

[jira] [Commented] (KAFKA-1733) Producer.send will block indeterminately when broker is unavailable.

[ https://issues.apache.org/jira/browse/KAFKA-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204294#comment-14204294 ] Neha Narkhede commented on KAFKA-1733: -- +1 on getting this in 0.8.2 > Producer.send

[jira] [Commented] (KAFKA-1754) KOYA - Kafka on YARN

[ https://issues.apache.org/jira/browse/KAFKA-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204291#comment-14204291 ] Gwen Shapira commented on KAFKA-1754: - [~nehanarkhede] I agree that these are two seri

Re: Review Request 27723: Patch for KAFKA-1739

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/27723/#review60533 --- Ship it! Ship It! - Neha Narkhede On Nov. 7, 2014, 12:26 p.m., M

[jira] [Commented] (KAFKA-1460) NoReplicaOnlineException: No replica for partition

[ https://issues.apache.org/jira/browse/KAFKA-1460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204271#comment-14204271 ] Neha Narkhede commented on KAFKA-1460: -- Firstly, this deployment is a weak production

[jira] [Commented] (KAFKA-1754) KOYA - Kafka on YARN

[ https://issues.apache.org/jira/browse/KAFKA-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204267#comment-14204267 ] Neha Narkhede commented on KAFKA-1754: -- bq. Streaming applications such as Samza, Spa

[jira] [Updated] (KAFKA-1173) Using Vagrant to get up and running with Apache Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1173: - Reviewer: Joe Stein [~joestein] Feel free to reassign for review. > Using Vagrant to get up and r

[jira] [Commented] (KAFKA-1654) Provide a way to override server configuration from command line

[ https://issues.apache.org/jira/browse/KAFKA-1654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204259#comment-14204259 ] Neha Narkhede commented on KAFKA-1654: -- bq. Does the reasoning resonate with you or w

[jira] [Commented] (KAFKA-1742) ControllerContext removeTopic does not correctly update state

[ https://issues.apache.org/jira/browse/KAFKA-1742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204256#comment-14204256 ] Neha Narkhede commented on KAFKA-1742: -- +1 on the change but I think we don't want to

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204246#comment-14204246 ] Neha Narkhede commented on KAFKA-1282: -- good catch [~nmarasoi]. +1 on your change >

Re: Review Request 27534: Patch for KAFKA-1746

> On Nov. 8, 2014, 3:01 a.m., Mayuresh Gharat wrote: > > system_test/utils/kafka_system_test_utils.py, line 2403 > > > > > > This causes many system tests (approx 98) to fail Can you give list of a few that now fail

[jira] [Comment Edited] (KAFKA-493) High CPU usage on inactive server

[ https://issues.apache.org/jira/browse/KAFKA-493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204204#comment-14204204 ] Jing Dong edited comment on KAFKA-493 at 11/10/14 12:49 AM: Thi

[jira] [Updated] (KAFKA-493) High CPU usage on inactive server

[ https://issues.apache.org/jira/browse/KAFKA-493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Dong updated KAFKA-493: Attachment: Kafka-2014-11-10.snapshot.zip This is a production high CPU usage snapshot. We used similar amoun

Support for topics+streams at class WildcardStreamsHandler

Hi guys, i have seen that if create a message stream by using: createMessageStreams I can define a map with Topic->#Streams Is there a reason why createMessageStreamsByFilter us not giving the same support? I have only a TopicFilter and numStreams interface such as: public List> createMessageSt