partition key patch

2013-07-17 Thread Jay Kreps
Any one able to take a look at this? https://issues.apache.org/jira/browse/KAFKA-925 -Jay

[jira] [Updated] (KAFKA-925) Add optional partition key override in producer

2013-07-17 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-925: Attachment: KAFKA-925-v2.patch Updated patch--rebased to trunk. Add optional partition

Re: partition key patch

2013-07-17 Thread Wang Guozhang
I will do it. On Wed, Jul 17, 2013 at 2:17 PM, Jay Kreps jay.kr...@gmail.com wrote: Any one able to take a look at this? https://issues.apache.org/jira/browse/KAFKA-925 -Jay -- -- Guozhang

[jira] [Commented] (KAFKA-925) Add optional partition key override in producer

2013-07-17 Thread Chris Riccomini (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13711676#comment-13711676 ] Chris Riccomini commented on KAFKA-925: --- Hey Jay, Seems pretty reasonable to me. Is

[jira] [Updated] (KAFKA-615) Avoid fsync on log segment roll

2013-07-17 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-615: Attachment: KAFKA-615-v4.patch Rebased patch to trunk. Avoid fsync on log segment roll

[jira] [Commented] (KAFKA-925) Add optional partition key override in producer

2013-07-17 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13711690#comment-13711690 ] Guozhang Wang commented on KAFKA-925: - Hi Jay, In the DefaultEventHandler, only the

[jira] [Commented] (KAFKA-925) Add optional partition key override in producer

2013-07-17 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13711707#comment-13711707 ] Jay Kreps commented on KAFKA-925: - Yes the idea of this feature is to make it possible to

[jira] [Commented] (KAFKA-925) Add optional partition key override in producer

2013-07-17 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13711709#comment-13711709 ] Jay Kreps commented on KAFKA-925: - It is definitely true that downstream consumers cannot

[jira] [Created] (KAFKA-979) Add jitter for time based rolling

2013-07-17 Thread Sriram Subramanian (JIRA)
Sriram Subramanian created KAFKA-979: Summary: Add jitter for time based rolling Key: KAFKA-979 URL: https://issues.apache.org/jira/browse/KAFKA-979 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-979) Add jitter for time based rolling

2013-07-17 Thread Swapnil Ghike (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13712002#comment-13712002 ] Swapnil Ghike commented on KAFKA-979: - Hey Sriram, can you explain what we are trying