[jira] [Commented] (KAFKA-1308) Publish jar of test utilities to Maven

[ https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14037468#comment-14037468 ] Chris Campbell commented on KAFKA-1308: --- For what its worth, the main reason I creat

[jira] [Resolved] (KAFKA-564) Wildcard-based topic consumption should assign partitions to threads uniformly

[ https://issues.apache.org/jira/browse/KAFKA-564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy resolved KAFKA-564. -- Resolution: Duplicate KAFKA-687 is a little more general than this. > Wildcard-based topic consumption

[jira] [Commented] (KAFKA-687) Rebalance algorithm should consider partitions from all topics

[ https://issues.apache.org/jira/browse/KAFKA-687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14037620#comment-14037620 ] Joel Koshy commented on KAFKA-687: -- Although we are working on the new consumer, some peop

[jira] [Commented] (KAFKA-1374) LogCleaner (compaction) does not support compressed topics

[ https://issues.apache.org/jira/browse/KAFKA-1374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14037669#comment-14037669 ] Joel Koshy commented on KAFKA-1374: --- I had started on this a while ago, but did not fini

[jira] Subscription: outstanding kafka patches

Issue Subscription Filter: outstanding kafka patches (94 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-1496 Using batch message in sync producer only sends the first message if we use a Scala Stream as the argument https://iss

Re: Review Request 22762: Patch for KAFKA-1316

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/22762/ --- (Updated June 19, 2014, 9:01 p.m.) Review request for kafka. Summary (updated

[jira] [Commented] (KAFKA-1316) Refactor Sender

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

[jira] [Updated] (KAFKA-1316) Refactor Sender

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1316: - Attachment: KAFKA-1316_2014-06-19_14:01:04.patch > Refactor Sender > --- > >

[jira] [Updated] (KAFKA-1291) Make wrapper shell scripts for important tools

[ https://issues.apache.org/jira/browse/KAFKA-1291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1291: - Resolution: Fixed Status: Resolved (was: Patch Available) [~nehanarkhede] I fixed the simple per

Re: Review Request 22496: Patch for KAFKA-1096

> On June 19, 2014, 4:29 a.m., Neha Narkhede wrote: > > core/src/main/scala/kafka/controller/KafkaController.scala, line 172 > > > > > > I think this should be removed as well. Basically, the only time the > > broker

[jira] [Created] (KAFKA-1498) new producer performance and bug improvements

Jun Rao created KAFKA-1498: -- Summary: new producer performance and bug improvements Key: KAFKA-1498 URL: https://issues.apache.org/jira/browse/KAFKA-1498 Project: Kafka Issue Type: Bug Com

[jira] [Updated] (KAFKA-1498) new producer performance and bug improvements

[ https://issues.apache.org/jira/browse/KAFKA-1498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1498: --- Attachment: kafka-1498.patch Attache a draft patch of revision dcc88408c98a07cb9a816ab55cd81e55f1d2217d on J

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

See

[jira] [Updated] (KAFKA-687) Rebalance algorithm should consider partitions from all topics

[ https://issues.apache.org/jira/browse/KAFKA-687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-687: Assignee: Sriharsha Chintalapani > Rebalance algorithm should consider partitions from all topics >

[jira] [Updated] (KAFKA-1374) LogCleaner (compaction) does not support compressed topics

[ https://issues.apache.org/jira/browse/KAFKA-1374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1374: - Labels: newbie++ (was: ) > LogCleaner (compaction) does not support compressed topics >

[jira] [Created] (KAFKA-1499) Broker-side compression configuration

Joel Koshy created KAFKA-1499: - Summary: Broker-side compression configuration Key: KAFKA-1499 URL: https://issues.apache.org/jira/browse/KAFKA-1499 Project: Kafka Issue Type: New Feature

[jira] [Created] (KAFKA-1500) adding new consumer requests using the new protocol

Jun Rao created KAFKA-1500: -- Summary: adding new consumer requests using the new protocol Key: KAFKA-1500 URL: https://issues.apache.org/jira/browse/KAFKA-1500 Project: Kafka Issue Type: Improvement

[jira] [Comment Edited] (KAFKA-1498) new producer performance and bug improvements

[ https://issues.apache.org/jira/browse/KAFKA-1498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14037932#comment-14037932 ] Jun Rao edited comment on KAFKA-1498 at 6/20/14 12:31 AM: -- Attach

[jira] [Updated] (KAFKA-1500) adding new consumer requests using the new protocol

[ https://issues.apache.org/jira/browse/KAFKA-1500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1500: --- Attachment: kafka-1500.patch Attached is a draft patch based off revision bf7fb63218640873781720a494d1114fbe

[jira] [Created] (KAFKA-1501) transient unit tests failures due to port already in use

Jun Rao created KAFKA-1501: -- Summary: transient unit tests failures due to port already in use Key: KAFKA-1501 URL: https://issues.apache.org/jira/browse/KAFKA-1501 Project: Kafka Issue Type: Improv

[jira] [Updated] (KAFKA-1501) transient unit tests failures due to port already in use

[ https://issues.apache.org/jira/browse/KAFKA-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1501: --- Labels: newbie (was: ) > transient unit tests failures due to port already in use >

[jira] [Commented] (KAFKA-1501) transient unit tests failures due to port already in use

[ https://issues.apache.org/jira/browse/KAFKA-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14038179#comment-14038179 ] Jun Rao commented on KAFKA-1501: In some of the unit tests, we obtain an open port once an

[jira] [Commented] (KAFKA-1500) adding new consumer requests using the new protocol

[ https://issues.apache.org/jira/browse/KAFKA-1500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14038421#comment-14038421 ] darion yaphets commented on KAFKA-1500: --- why we don't use protobuf as kafka's proces

[jira] [Updated] (KAFKA-1308) Publish jar of test utilities to Maven

[ https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jakob Homan updated KAFKA-1308: --- Attachment: KAFKA-1308.patch KAFKA-1308-8.1.1.patch Patches for both trunk and 8.1.1

Review Request 22802: KAFKA-1308, publish test jars

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/22802/ --- Review request for kafka. Repository: kafka Description --- Publish test

[jira] [Commented] (KAFKA-1308) Publish jar of test utilities to Maven

[ https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14038469#comment-14038469 ] Jakob Homan commented on KAFKA-1308: The patches are identical, just slight differing

[jira] [Commented] (KAFKA-1308) Publish jar of test utilities to Maven

[ https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14038473#comment-14038473 ] Jakob Homan commented on KAFKA-1308: rb: https://reviews.apache.org/r/22802/ > Publis

Re: Review Request 22496: Patch for KAFKA-1096

> On June 19, 2014, 4:29 a.m., Neha Narkhede wrote: > > core/src/main/scala/kafka/controller/KafkaController.scala, line 172 > > > > > > I think this should be removed as well. Basically, the only time the > > broker

Re: Review Request 22802: KAFKA-1308, publish test jars

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/22802/#review46258 --- Ship it! Ship It! - Neha Narkhede On June 20, 2014, 5:27 a.m., J