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

[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

[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-tabpanelfocusedCommentId=14204204#comment-14204204 ] Jing Dong edited comment on KAFKA-493 at 11/10/14 12:49 AM:

[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-tabpanelfocusedCommentId=14204246#comment-14204246 ] Neha Narkhede commented on KAFKA-1282: -- good catch [~nmarasoi]. +1 on your change

[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-tabpanelfocusedCommentId=14204256#comment-14204256 ] Neha Narkhede commented on KAFKA-1742: -- +1 on the change but I think we don't want to

[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-tabpanelfocusedCommentId=14204259#comment-14204259 ] Neha Narkhede commented on KAFKA-1654: -- bq. Does the reasoning resonate with you or

[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

[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-tabpanelfocusedCommentId=14204271#comment-14204271 ] Neha Narkhede commented on KAFKA-1460: -- Firstly, this deployment is a weak production

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-1476) Get a list of consumer groups

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

[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-tabpanelfocusedCommentId=14204310#comment-14204310 ] Neha Narkhede commented on KAFKA-1654: -- Thanks for the updated patch. Here are my

[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

[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-tabpanelfocusedCommentId=14204323#comment-14204323 ] Neha Narkhede commented on KAFKA-328: - Few review comments- 1. Can you please use

[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

[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

[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] [Commented] (KAFKA-1760) Implement new consumer client

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

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

[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] [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] [Commented] (KAFKA-1760) Implement new consumer client

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

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

See https://builds.apache.org/job/Kafka-trunk/326/changes

[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-tabpanelfocusedCommentId=14204442#comment-14204442 ] Jarek Jarcec Cecho commented on KAFKA-1654: --- Thank you for your additional

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] [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-tabpanelfocusedCommentId=14204467#comment-14204467 ] Vladimir Tretyakov commented on KAFKA-1481: --- Hi [~jjkoshy] thx for your