[jira] Subscription: outstanding kafka patches

2012-08-20 Thread jira
Issue Subscription Filter: outstanding kafka patches (52 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-468 String#getBytes is platform dependent https://issues.apache.org/jira/browse/KAFKA-468 KAFKA-465 Performance te

[jira] [Commented] (KAFKA-376) expose different data to fetch requests from the follower replicas and consumer clients

2012-08-20 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13437933#comment-13437933 ] Jun Rao commented on KAFKA-376: --- Prashanth, thanks for the updates. 1) We have a separate j

[jira] [Created] (KAFKA-472) update metadata in batches in Producer

2012-08-20 Thread Jun Rao (JIRA)
Jun Rao created KAFKA-472: - Summary: update metadata in batches in Producer Key: KAFKA-472 URL: https://issues.apache.org/jira/browse/KAFKA-472 Project: Kafka Issue Type: Bug Components: co

[jira] [Created] (KAFKA-473) Use getMetadata Api in ZookeeperConsumerConnector

2012-08-20 Thread Jun Rao (JIRA)
Jun Rao created KAFKA-473: - Summary: Use getMetadata Api in ZookeeperConsumerConnector Key: KAFKA-473 URL: https://issues.apache.org/jira/browse/KAFKA-473 Project: Kafka Issue Type: Bug Com

[jira] [Created] (KAFKA-474) support changing host/port of a broker

2012-08-20 Thread Jun Rao (JIRA)
Jun Rao created KAFKA-474: - Summary: support changing host/port of a broker Key: KAFKA-474 URL: https://issues.apache.org/jira/browse/KAFKA-474 Project: Kafka Issue Type: Bug Components: co

[jira] [Commented] (KAFKA-340) ensure ISR has enough brokers during clean shutdown of a broker

2012-08-20 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13437978#comment-13437978 ] Jun Rao commented on KAFKA-340: --- For this to happen, each broker needs to know the # of repli

[jira] [Commented] (KAFKA-351) Refactor some new components introduced for replication

2012-08-20 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13437994#comment-13437994 ] Neha Narkhede commented on KAFKA-351: - Thanks for incorporating review suggestions! 2.

[jira] [Commented] (KAFKA-139) cross-compile multiple Scala versions

2012-08-20 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13438000#comment-13438000 ] Neha Narkhede commented on KAFKA-139: - 3. In the earlier SBT version, if you run ./sbt

[jira] [Commented] (KAFKA-139) cross-compile multiple Scala versions

2012-08-20 Thread derek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13438005#comment-13438005 ] derek commented on KAFKA-139: - 3. SBT now does dependency management all the way to the produce

[jira] [Commented] (KAFKA-139) cross-compile multiple Scala versions

2012-08-20 Thread derek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13438006#comment-13438006 ] derek commented on KAFKA-139: - Sorry, to answer your last question I'd be happy to work out the

[jira] [Commented] (KAFKA-139) cross-compile multiple Scala versions

2012-08-20 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13438008#comment-13438008 ] Neha Narkhede commented on KAFKA-139: - 3. Sounds good, let's not change anything here.

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

2012-08-20 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-398: -- Affects Version/s: (was: 0.8) (was: 0.7) 0.8.1 > Enhan

[jira] [Updated] (KAFKA-469) Message size is not checked at the server

2012-08-20 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-469: -- Fix Version/s: (was: 0.7.1) 0.7.2 > Message size is not checked at the server > -

[jira] [Updated] (KAFKA-461) remove support for format for magic byte 0 in 0.8

2012-08-20 Thread Swapnil Ghike (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-461: Attachment: kafka-461-v2.patch Made the above changes and rebased. > remove support

[jira] [Commented] (KAFKA-440) Create a regression test framework for distributed environment testing

2012-08-20 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13438063#comment-13438063 ] Neha Narkhede commented on KAFKA-440: - This time it fails with the following error - 2

[jira] [Commented] (KAFKA-440) Create a regression test framework for distributed environment testing

2012-08-20 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13438099#comment-13438099 ] Neha Narkhede commented on KAFKA-440: - My bad, I forgot to replace kafka_home in cluste

[jira] [Commented] (KAFKA-440) Create a regression test framework for distributed environment testing

2012-08-20 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13438113#comment-13438113 ] Neha Narkhede commented on KAFKA-440: - Also, when I run the test, the data validation f

[jira] [Updated] (KAFKA-356) Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly

2012-08-20 Thread Yang Ye (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Ye updated KAFKA-356: -- Attachment: kafka_356_v6.diff Fix the log so that the system test passes > Create a generic K

Re: Build failed in Jenkins: Kafka-0.8 #23

2012-08-20 Thread Jay Kreps
It looks like these problems come from the tests not being reentrant due to using hard-coded ports. Hard-coding ports is a problem because our tests may run at the same time for different branches or may run on the same test server as other tests that are using that port. There is not reason to us

[jira] [Updated] (KAFKA-440) Create a regression test framework for distributed environment testing

2012-08-20 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-440: Attachment: kafka-440-v6.patch Uploaded kafka-440-v6.patch with the following changes: 1. Updated README.tx

[jira] [Resolved] (KAFKA-356) Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly

2012-08-20 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-356. --- Resolution: Fixed Fix Version/s: 0.8 Thanks for patch v6. Committed to 0.8 after removing unused import

[jira] [Closed] (KAFKA-356) Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly

2012-08-20 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao closed KAFKA-356. - > Create a generic Kafka thread class that includes basic boiler plate code of > instantiating and shutting down

[jira] [Created] (KAFKA-475) Time based log segment rollout

2012-08-20 Thread Swapnil Ghike (JIRA)
Swapnil Ghike created KAFKA-475: --- Summary: Time based log segment rollout Key: KAFKA-475 URL: https://issues.apache.org/jira/browse/KAFKA-475 Project: Kafka Issue Type: New Feature Affects

[jira] [Updated] (KAFKA-475) Time based log segment rollout

2012-08-20 Thread Swapnil Ghike (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-475: Status: Patch Available (was: In Progress) > Time based log segment rollout > -

[jira] [Work started] (KAFKA-475) Time based log segment rollout

2012-08-20 Thread Swapnil Ghike (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-475 started by Swapnil Ghike. > Time based log segment rollout > -- > > Key: KAFKA-475 > URL: htt

[jira] [Updated] (KAFKA-475) Time based log segment rollout

2012-08-20 Thread Swapnil Ghike (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-475: Attachment: kafka-475-v1.patch To facilitate this, we can roll out a new log segment whenever a time

[jira] [Closed] (KAFKA-461) remove support for format for magic byte 0 in 0.8

2012-08-20 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao closed KAFKA-461. - > remove support for format for magic byte 0 in 0.8 > - > >

[jira] [Updated] (KAFKA-461) remove support for format for magic byte 0 in 0.8

2012-08-20 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-461: -- Resolution: Fixed Status: Resolved (was: Patch Available) Thanks for patch v2. Committed to 0.8

[jira] [Updated] (KAFKA-351) Refactor some new components introduced for replication

2012-08-20 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-351: -- Attachment: kafka-351_v6.patch Thanks for the review. Attach patch v6. 5.1 Changed logEndOffsetUpdateTime to At