[jira] [Commented] (KAFKA-649) Cleanup log4j logging

2013-01-13 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13552283#comment-13552283 ] Neha Narkhede commented on KAFKA-649: - Jay, would you like to take this on ?

[jira] [Commented] (KAFKA-691) Fault tolerance broken with replication factor 1

2013-01-13 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13552336#comment-13552336 ] Jun Rao commented on KAFKA-691: --- It would be great if you can provide a patch. 1,2,3. Yes,

[jira] [Commented] (KAFKA-693) Consumer rebalance fails if no leader available for a partition and stops all fetchers

2013-01-13 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13552341#comment-13552341 ] Jun Rao commented on KAFKA-693: --- Ok. This is actually a real problem. During rebalance, we

[jira] [Commented] (KAFKA-695) Broker shuts down due to attempt to read a closed index file

2013-01-13 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13552342#comment-13552342 ] Jun Rao commented on KAFKA-695: --- The weird thing is that the file actually exists on disk

[jira] [Commented] (KAFKA-691) Fault tolerance broken with replication factor 1

2013-01-13 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13552363#comment-13552363 ] Jay Kreps commented on KAFKA-691: - Does batching make sense versus just having people

[jira] [Commented] (KAFKA-698) broker may expose uncommitted data to a consumer

2013-01-13 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13552375#comment-13552375 ] Jun Rao commented on KAFKA-698: --- My analysis is the following. In LogSegment.read(), we have

[jira] [Created] (KAFKA-699) Disallow clients to set replicaId in FetchRequest

2013-01-13 Thread Jun Rao (JIRA)
Jun Rao created KAFKA-699: - Summary: Disallow clients to set replicaId in FetchRequest Key: KAFKA-699 URL: https://issues.apache.org/jira/browse/KAFKA-699 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-698) broker may expose uncommitted data to a consumer

2013-01-13 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-698: -- Status: Patch Available (was: Open) broker may expose uncommitted data to a consumer

[jira] [Issue Comment Deleted] (KAFKA-698) broker may expose uncommitted data to a consumer

2013-01-13 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-698: -- Comment: was deleted (was: Attach a patch. It removes replicaId from javaapi.FetchRequest and restricts the

[jira] [Updated] (KAFKA-699) Disallow clients to set replicaId in FetchRequest

2013-01-13 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-699: -- Attachment: kafka-699.patch Attach a patch. It removes replicaId from javaapi.FetchRequest and restricts the