[jira] [Updated] (KAFKA-398) Enhance SocketServer to Enable Sending Requests

[ https://issues.apache.org/jira/browse/KAFKA-398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-398: Attachment: kafka-398-0.7-v1.patch This patch is based on 0.7, which is from my current implementati

[jira] [Updated] (KAFKA-398) Enhance SocketServer to Enable Sending Requests

[ https://issues.apache.org/jira/browse/KAFKA-398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-398: Affects Version/s: 0.7 > Enhance SocketServer to Enable Sending Requests > -

[jira] [Commented] (KAFKA-362) ZookeeperConsumerConnector needs to connect to new leader after leadership change

[ https://issues.apache.org/jira/browse/KAFKA-362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13411127#comment-13411127 ] Joel Koshy commented on KAFKA-362: -- +1 on v3 > ZookeeperConsumerConnector

[jira] [Updated] (KAFKA-399) 0.7.1 seems to show less performance than 0.7.0

[ https://issues.apache.org/jira/browse/KAFKA-399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dongmin Yu updated KAFKA-399: - Description: On a test, 0.7.1 seems to show less performance than 0.7.0. Producer is on a machine A, and

[jira] [Created] (KAFKA-399) 0.7.1 seems to show less performance than 0.7.0

Dongmin Yu created KAFKA-399: Summary: 0.7.1 seems to show less performance than 0.7.0 Key: KAFKA-399 URL: https://issues.apache.org/jira/browse/KAFKA-399 Project: Kafka Issue Type: Test

[jira] [Updated] (KAFKA-399) 0.7.1 seems to show less performance than 0.7.0

[ https://issues.apache.org/jira/browse/KAFKA-399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dongmin Yu updated KAFKA-399: - Attachment: dstat.txt DirSource.java > 0.7.1 seems to show less performance than 0.7.0

[jira] [Updated] (KAFKA-380) Enhance single_host_multi_brokers test with failure to trigger leader re-election in replication

[ https://issues.apache.org/jira/browse/KAFKA-380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-380: Attachment: kafka-380-v3.patch Thanks Jun. Uploaded kafka-380-v3.patch with the following changes: 1. Rebas

[jira] [Commented] (KAFKA-398) Enhance SocketServer to Enable Sending Requests

[ https://issues.apache.org/jira/browse/KAFKA-398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13410916#comment-13410916 ] Guozhang Wang commented on KAFKA-398: - In 0.7 SocketServer, the handler can only take t

[jira] [Created] (KAFKA-398) Enhance SocketServer to Enable Sending Requests

Guozhang Wang created KAFKA-398: --- Summary: Enhance SocketServer to Enable Sending Requests Key: KAFKA-398 URL: https://issues.apache.org/jira/browse/KAFKA-398 Project: Kafka Issue Type: Improve

[jira] [Commented] (KAFKA-397) kafka.common.InvalidMessageSizeException: null

[ https://issues.apache.org/jira/browse/KAFKA-397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13410691#comment-13410691 ] David Siegel commented on KAFKA-397: 2012-07-10T18:07:27.27635 [2012-07-10 18:07:27,275

[jira] [Commented] (KAFKA-397) kafka.common.InvalidMessageSizeException: null

[ https://issues.apache.org/jira/browse/KAFKA-397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13410671#comment-13410671 ] Jun Rao commented on KAFKA-397: --- Yes, if you wipe off the log. You need to clean up offsets i

[jira] [Commented] (KAFKA-397) kafka.common.InvalidMessageSizeException: null

[ https://issues.apache.org/jira/browse/KAFKA-397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13410660#comment-13410660 ] David Siegel commented on KAFKA-397: When we set the number of partitions per topic to

[jira] [Commented] (KAFKA-380) Enhance single_host_multi_brokers test with failure to trigger leader re-election in replication

[ https://issues.apache.org/jira/browse/KAFKA-380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13410646#comment-13410646 ] Jun Rao commented on KAFKA-380: --- Patch v2 doesn't apply after kafka-306 is committed. Could y

[jira] [Updated] (KAFKA-306) broker failure system test broken on replication branch

[ https://issues.apache.org/jira/browse/KAFKA-306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-306: -- Resolution: Fixed Fix Version/s: 0.8 Status: Resolved (was: Patch Available) John, thanks for

[jira] [Updated] (KAFKA-362) ZookeeperConsumerConnector needs to connect to new leader after leadership change

[ https://issues.apache.org/jira/browse/KAFKA-362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-362: -- Attachment: kafka-362_v3.patch Thanks for the review. Attach patch v3. 1a. fixed 1b. Didn't notice those configs

[jira] [Updated] (KAFKA-397) kafka.common.InvalidMessageSizeException: null

[ https://issues.apache.org/jira/browse/KAFKA-397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Siegel updated KAFKA-397: --- Attachment: kafka-logs-invalid-message-size-null.tar > kafka.common.InvalidMessageSizeException: n

[jira] [Created] (KAFKA-397) kafka.common.InvalidMessageSizeException: null

David Siegel created KAFKA-397: -- Summary: kafka.common.InvalidMessageSizeException: null Key: KAFKA-397 URL: https://issues.apache.org/jira/browse/KAFKA-397 Project: Kafka Issue Type: Bug Af

Re: Kafka: A Shepherd's view

Thanks! -Jay On Mon, Jul 9, 2012 at 7:41 PM, Franklin, Matthew B. wrote: > Report and community look great. I look forward to a future graduation > VOTE :) >

[jira] [Updated] (KAFKA-306) broker failure system test broken on replication branch

[ https://issues.apache.org/jira/browse/KAFKA-306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-306: Attachment: kafka-306-v9.patch Thanks Jun for reviewing. Your suggestion are made in kafka-306-v9.patch. Th