[jira] [Commented] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

2014-08-19 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14101929#comment-14101929 ] Joel Koshy commented on KAFKA-1510: --- [~nmarasoi] can you update your patch to do

Fwd: kafka TestUtils createBrokerConfig issue

2014-08-19 Thread Parin Jogani
Trying to write a unit test case for Kafka, and stuck with strange createBrokerConfig issue. on TestUtils.createBrokerConfigs(1) it gives me compilation error The method createBrokerConfigs(int, boolean) in the type TestUtils is not applicable for the arguments (int) When I looked into the

[GitHub] kafka pull request: Snappy update (RHEL4,5,6)

2014-08-19 Thread thinker0
GitHub user thinker0 opened a pull request: https://github.com/apache/kafka/pull/30 Snappy update (RHEL4,5,6) You can merge this pull request into a Git repository by running: $ git pull https://github.com/thinker0/kafka snappy-update Alternatively you can review and apply

[GitHub] kafka pull request: KAFKA-1369 - snappy version update 1.1.x

2014-08-19 Thread thinker0
GitHub user thinker0 opened a pull request: https://github.com/apache/kafka/pull/31 KAFKA-1369 - snappy version update 1.1.x You can merge this pull request into a Git repository by running: $ git pull https://github.com/thinker0/kafka snappy-update Alternatively you can

[jira] [Updated] (KAFKA-1369) snappy version update 1.1.x

2014-08-19 Thread thinker0 (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thinker0 updated KAFKA-1369: Status: Patch Available (was: Open) https://github.com/apache/kafka/pull/31 snappy version update 1.1.x

[jira] [Commented] (KAFKA-1369) snappy version update 1.1.x

2014-08-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102103#comment-14102103 ] ASF GitHub Bot commented on KAFKA-1369: --- GitHub user thinker0 opened a pull request:

[jira] [Created] (KAFKA-1600) Controller failover not working correctly.

2014-08-19 Thread Ding Haifeng (JIRA)
Ding Haifeng created KAFKA-1600: --- Summary: Controller failover not working correctly. Key: KAFKA-1600 URL: https://issues.apache.org/jira/browse/KAFKA-1600 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-1369) snappy version update 1.1.x

2014-08-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102234#comment-14102234 ] Jun Rao commented on KAFKA-1369: Could you attach the changes as a patch to this jira?

[jira] [Commented] (KAFKA-1597) New metrics: ResponseQueueSize and BeingSentResponses

2014-08-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102245#comment-14102245 ] Jun Rao commented on KAFKA-1597: The load on the broker is currently measured by

Re: Improving the Kafka client ecosystem

2014-08-19 Thread Mark Roberts
Did this mailing list ever get created? Was there consensus that it did or didn't need created? -Mark On Jul 18, 2014, at 14:34, Jay Kreps jay.kr...@gmail.com wrote: A question was asked in another thread about what was an effective way to contribute to the Kafka project for people who

[jira] [Commented] (KAFKA-1600) Controller failover not working correctly.

2014-08-19 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102419#comment-14102419 ] Guozhang Wang commented on KAFKA-1600: -- Hello Haifeng, Could you upload the broker

[jira] [Commented] (KAFKA-1351) String.format is very expensive in Scala

2014-08-19 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102420#comment-14102420 ] Guozhang Wang commented on KAFKA-1351: -- I think a simple for-loop with

[jira] [Commented] (KAFKA-1351) String.format is very expensive in Scala

2014-08-19 Thread Viktor Taranenko (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102466#comment-14102466 ] Viktor Taranenko commented on KAFKA-1351: - Sorry, to clarify, I mean testing Kafka

[jira] [Commented] (KAFKA-1597) New metrics: ResponseQueueSize and BeingSentResponses

2014-08-19 Thread Alexis Midon (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102480#comment-14102480 ] Alexis Midon commented on KAFKA-1597: - # NetworkProcessorAvgIdlePercent and

[jira] [Commented] (KAFKA-1485) Upgrade to Zookeeper 3.4.6 and create shim for ZKCLI so system tests can run

2014-08-19 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102495#comment-14102495 ] Gwen Shapira commented on KAFKA-1485: - Sounds good to me. The first patch attached to

Re: Review Request 23906: Patch for KAFKA-1527

2014-08-19 Thread Raul Castro Fernandez
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23906/ --- (Updated Aug. 19, 2014, 5:39 p.m.) Review request for kafka. Bugs:

[jira] [Commented] (KAFKA-1527) SimpleConsumer should be transaction-aware

2014-08-19 Thread Raul Castro Fernandez (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102513#comment-14102513 ] Raul Castro Fernandez commented on KAFKA-1527: -- Updated reviewboard

[jira] [Updated] (KAFKA-1527) SimpleConsumer should be transaction-aware

2014-08-19 Thread Raul Castro Fernandez (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raul Castro Fernandez updated KAFKA-1527: - Attachment: KAFKA-1527_2014-08-19_10:39:53.patch SimpleConsumer should be

[jira] [Created] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

2014-08-19 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-1601: --- Summary: ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware Key: KAFKA-1601 URL: https://issues.apache.org/jira/browse/KAFKA-1601 Project: Kafka

[jira] [Updated] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1601: Assignee: Dong Lin ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

Review Request 24856: Patch for KAFKA-1601

2014-08-19 Thread Dong Lin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24856/ --- Review request for kafka. Bugs: KAFKA-1601

[jira] [Updated] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1601: Attachment: KAFKA-1601.patch ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

[jira] [Commented] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102540#comment-14102540 ] Dong Lin commented on KAFKA-1601: - Created reviewboard

[jira] [Updated] (KAFKA-1526) Producer performance tool should have an option to enable transactions

2014-08-19 Thread Raul Castro Fernandez (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raul Castro Fernandez updated KAFKA-1526: - Attachment: KAFKA-1526_2014-08-19_10:54:51.patch Producer performance tool

Re: Review Request 23647: Patch for KAFKA-1526

2014-08-19 Thread Raul Castro Fernandez
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23647/ --- (Updated Aug. 19, 2014, 5:54 p.m.) Review request for kafka. Bugs:

[jira] [Commented] (KAFKA-1526) Producer performance tool should have an option to enable transactions

2014-08-19 Thread Raul Castro Fernandez (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102543#comment-14102543 ] Raul Castro Fernandez commented on KAFKA-1526: -- Updated reviewboard

[jira] [Commented] (KAFKA-656) Add Quotas to Kafka

2014-08-19 Thread Abhinav Anand (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102552#comment-14102552 ] Abhinav Anand commented on KAFKA-656: - Hi [~jkreps], Thanks for the inputs. I am

[jira] [Commented] (KAFKA-1600) Controller failover not working correctly.

2014-08-19 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102575#comment-14102575 ] Neha Narkhede commented on KAFKA-1600: -- [~dinghaifeng], thanks for reporting the

[jira] [Updated] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1601: Description: Implement buffered consumer logic in ConsumerTransactionBuffer class. The class takes as

[jira] [Commented] (KAFKA-1351) String.format is very expensive in Scala

2014-08-19 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102584#comment-14102584 ] Neha Narkhede commented on KAFKA-1351: -- Hey [~viktortnk], if you want to measure the

[jira] [Commented] (KAFKA-1400) transient unit test failure in SocketServerTest

2014-08-19 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102592#comment-14102592 ] Neha Narkhede commented on KAFKA-1400: -- [~gwenshap], to see if you are observing the

[jira] [Updated] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1601: Description: Implement buffered consumer logic in ConsumerTransactionBuffer class. The class takes as

[jira] [Commented] (KAFKA-1597) New metrics: ResponseQueueSize and BeingSentResponses

2014-08-19 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102600#comment-14102600 ] Neha Narkhede commented on KAFKA-1597: -- +1 on measuring the responses being sent and

[jira] [Commented] (KAFKA-1558) AdminUtils.deleteTopic does not work

2014-08-19 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102617#comment-14102617 ] Neha Narkhede commented on KAFKA-1558: -- [~clarkhaskins], please can you attach all

Re: Review Request 23655: Patch for KAFKA-687

2014-08-19 Thread Joel Koshy
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23655/ --- (Updated Aug. 19, 2014, 7:08 p.m.) Review request for kafka. Bugs: KAFKA-687

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

2014-08-19 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102664#comment-14102664 ] Joel Koshy commented on KAFKA-687: -- Updated reviewboard

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

2014-08-19 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy updated KAFKA-687: - Attachment: KAFKA-687_2014-08-19_12:07:37.patch Rebalance algorithm should consider partitions from all

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

2014-08-19 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy updated KAFKA-687: - Status: Patch Available (was: Open) Rebalance algorithm should consider partitions from all topics

[jira] [Commented] (KAFKA-1351) String.format is very expensive in Scala

2014-08-19 Thread Viktor Taranenko (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102729#comment-14102729 ] Viktor Taranenko commented on KAFKA-1351: - I was just comparing results in single

[jira] [Comment Edited] (KAFKA-1351) String.format is very expensive in Scala

2014-08-19 Thread Viktor Taranenko (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102729#comment-14102729 ] Viktor Taranenko edited comment on KAFKA-1351 at 8/19/14 8:01 PM:

kafka TestUtils createBrokerConfig issue

2014-08-19 Thread Parin Jogani
Trying to write a unit test case for Kafka, and stuck with strange createBrokerConfig issue. on TestUtils.createBrokerConfigs(1) it gives me compilation error The method createBrokerConfigs(int, boolean) in the type TestUtils is not applicable for the arguments (int) When I looked into the

[jira] [Resolved] (KAFKA-1522) Transactional messaging request/response definitions

2014-08-19 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy resolved KAFKA-1522. --- Resolution: Fixed Transactional messaging request/response definitions

[jira] [Created] (KAFKA-1602) Use single error code for offset commit response

2014-08-19 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-1602: Summary: Use single error code for offset commit response Key: KAFKA-1602 URL: https://issues.apache.org/jira/browse/KAFKA-1602 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-1603) MirrorMaker consumer does not put the message key into ProducerRecord

2014-08-19 Thread Jiangjie Qin (JIRA)
Jiangjie Qin created KAFKA-1603: --- Summary: MirrorMaker consumer does not put the message key into ProducerRecord Key: KAFKA-1603 URL: https://issues.apache.org/jira/browse/KAFKA-1603 Project: Kafka

Review Request 24869: Patch for KAFKA-1603

2014-08-19 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24869/ --- Review request for kafka. Bugs: KAFKA-1603

[jira] [Updated] (KAFKA-1603) MirrorMaker consumer does not put the message key into ProducerRecord

2014-08-19 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1603: Assignee: Jiangjie Qin Status: Patch Available (was: Open) MirrorMaker consumer does not

[jira] [Updated] (KAFKA-1603) MirrorMaker consumer does not put the message key into ProducerRecord

2014-08-19 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1603: Attachment: KAFKA-1603.patch MirrorMaker consumer does not put the message key into

[jira] [Commented] (KAFKA-1603) MirrorMaker consumer does not put the message key into ProducerRecord

2014-08-19 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14102915#comment-14102915 ] Jiangjie Qin commented on KAFKA-1603: - Created reviewboard

Re: Review Request 24869: Patch for KAFKA-1603

2014-08-19 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24869/#review51041 --- Ship it! Ship It! - Guozhang Wang On Aug. 19, 2014, 9:50 p.m.,

[jira] [Updated] (KAFKA-1602) Use single error code for offset commit response

2014-08-19 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy updated KAFKA-1602: -- Description: As discussed with Joel offline, today the offset commit response contains an error code

[jira] [Created] (KAFKA-1604) System Test for Transaction Management

2014-08-19 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-1604: --- Summary: System Test for Transaction Management Key: KAFKA-1604 URL: https://issues.apache.org/jira/browse/KAFKA-1604 Project: Kafka Issue Type: Test

Review Request 24874: Patch for KAFKA-1601

2014-08-19 Thread Dong Lin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24874/ --- Review request for kafka. Bugs: KAFKA-1601

[jira] [Updated] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1601: Attachment: KAFKA-1601.patch ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

[jira] [Issue Comment Deleted] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1601: Comment: was deleted (was: Created reviewboard https://reviews.apache.org/r/24874/diff/ against branch

[jira] [Updated] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1601: Attachment: (was: KAFKA-1601.patch) ConsoleConsumer/SimpleConsumerPerformance should be

[jira] [Commented] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14103123#comment-14103123 ] Dong Lin commented on KAFKA-1601: - Created reviewboard

Re: Review Request 24874: Patch for KAFKA-1601

2014-08-19 Thread Dong Lin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24874/ --- (Updated Aug. 20, 2014, 12:18 a.m.) Review request for kafka. Bugs:

Re: Review Request 24874: Patch for KAFKA-1604

2014-08-19 Thread Dong Lin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24874/ --- (Updated Aug. 20, 2014, 12:19 a.m.) Review request for kafka. Summary

Re: Review Request 24874: Patch for KAFKA-1604

2014-08-19 Thread Dong Lin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24874/ --- (Updated Aug. 20, 2014, 12:28 a.m.) Review request for kafka. Bugs:

[jira] [Commented] (KAFKA-1604) System Test for Transaction Management

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14103137#comment-14103137 ] Dong Lin commented on KAFKA-1604: - Updated reviewboard

[jira] [Commented] (KAFKA-1604) System Test for Transaction Management

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14103136#comment-14103136 ] Dong Lin commented on KAFKA-1604: - Created reviewboard

[jira] [Updated] (KAFKA-1604) System Test for Transaction Management

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1604: Attachment: KAFKA-1604_2014-08-19_17:28:19.patch System Test for Transaction Management

Re: Review Request 24874: Patch for KAFKA-1604

2014-08-19 Thread Dong Lin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24874/ --- (Updated Aug. 20, 2014, 12:31 a.m.) Review request for kafka. Bugs:

[jira] [Updated] (KAFKA-1604) System Test for Transaction Management

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1604: Attachment: KAFKA-1604_2014-08-19_17:31:16.patch System Test for Transaction Management

[jira] [Commented] (KAFKA-1604) System Test for Transaction Management

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14103141#comment-14103141 ] Dong Lin commented on KAFKA-1604: - Updated reviewboard

[jira] [Updated] (KAFKA-1523) Implement transaction manager module

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1523: Description: * Entry point for transaction requests * Appends transaction control records to the

[jira] [Resolved] (KAFKA-1565) Transaction manager failover handling

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-1565. - Resolution: Duplicate Merged into KAFKA-1523: Implement transaction manager module. Transaction

[jira] [Closed] (KAFKA-1565) Transaction manager failover handling

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed KAFKA-1565. --- Merged into KAFKA-1523: Implement transaction manager module Transaction manager failover handling

[jira] [Closed] (KAFKA-1550) Patch review tool should use git format-patch to generate patch

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed KAFKA-1550. --- Patch review tool should use git format-patch to generate patch

[jira] [Closed] (KAFKA-1582) System Test should wait for producer to finish

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed KAFKA-1582. --- System Test should wait for producer to finish --

[jira] [Updated] (KAFKA-1603) MirrorMaker consumer does not put the message key into ProducerRecord

2014-08-19 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1603: --- Resolution: Fixed Fix Version/s: 0.8.2 Status: Resolved (was: Patch Available) Thanks for

[jira] [Updated] (KAFKA-1369) snappy version update 1.1.x

2014-08-19 Thread thinker0 (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thinker0 updated KAFKA-1369: Attachment: patch.diff patch.diff snappy version update 1.1.x

Re: Review Request 23906: Patch for KAFKA-1527

2014-08-19 Thread Raul Castro Fernandez
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23906/ --- (Updated Aug. 20, 2014, 1:22 a.m.) Review request for kafka. Bugs:

[jira] [Commented] (KAFKA-1527) SimpleConsumer should be transaction-aware

2014-08-19 Thread Raul Castro Fernandez (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14103195#comment-14103195 ] Raul Castro Fernandez commented on KAFKA-1527: -- Updated reviewboard

[jira] [Updated] (KAFKA-1527) SimpleConsumer should be transaction-aware

2014-08-19 Thread Raul Castro Fernandez (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raul Castro Fernandez updated KAFKA-1527: - Attachment: KAFKA-1527_2014-08-19_18:22:26.patch SimpleConsumer should be

[jira] [Updated] (KAFKA-1569) Tool for performance and correctness of transactions end-to-end

2014-08-19 Thread Raul Castro Fernandez (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raul Castro Fernandez updated KAFKA-1569: - Summary: Tool for performance and correctness of transactions end-to-end (was:

[jira] [Commented] (KAFKA-1565) Transaction manager failover handling

2014-08-19 Thread Raul Castro Fernandez (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14103205#comment-14103205 ] Raul Castro Fernandez commented on KAFKA-1565: -- If this patch is not

Re: Review Request 24856: Patch for KAFKA-1601

2014-08-19 Thread Joel Koshy
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24856/#review51050 --- Looks good overall, although you are probably aware of the caveats

Re: Review Request 24417: Patch for KAFKA-1541

2014-08-19 Thread Joel Koshy
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24417/#review51054 --- Ship it! Ship It! - Joel Koshy On Aug. 6, 2014, 7:54 p.m., Raul

Re: Review Request 23569: Patch for KAFKA-1525

2014-08-19 Thread Joel Koshy
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23569/#review51055 --- Ship it! Ship It! - Joel Koshy On Aug. 15, 2014, 6:49 p.m.,

[jira] [Commented] (KAFKA-1565) Transaction manager failover handling

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14103232#comment-14103232 ] Dong Lin commented on KAFKA-1565: - Sure. The JIRA is closed. Transaction manager

[jira] [Commented] (KAFKA-1400) transient unit test failure in SocketServerTest

2014-08-19 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14103285#comment-14103285 ] Gwen Shapira commented on KAFKA-1400: - Good idea. Will do that next time the issue

[jira] [Updated] (KAFKA-1369) snappy version update 1.1.x

2014-08-19 Thread thinker0 (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thinker0 updated KAFKA-1369: Attachment: (was: patch.diff) snappy version update 1.1.x ---

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

2014-08-19 Thread Apache Jenkins Server
See https://builds.apache.org/job/Kafka-trunk/253/changes

Re: Review Request 24874: Patch for KAFKA-1601

2014-08-19 Thread Dong Lin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24874/ --- (Updated Aug. 20, 2014, 4:06 a.m.) Review request for kafka. Summary

Re: Review Request 24874: Patch for KAFKA-1604

2014-08-19 Thread Dong Lin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24874/ --- (Updated Aug. 20, 2014, 4:07 a.m.) Review request for kafka. Summary

[jira] [Updated] (KAFKA-1604) System Test for Transaction Management

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1604: Attachment: KAFKA-1604_2014-08-19_21:07:35.patch System Test for Transaction Management

[jira] [Commented] (KAFKA-1604) System Test for Transaction Management

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14103343#comment-14103343 ] Dong Lin commented on KAFKA-1604: - Updated reviewboard

Re: Review Request 24856: Patch for KAFKA-1601

2014-08-19 Thread Dong Lin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24856/ --- (Updated Aug. 20, 2014, 4:10 a.m.) Review request for kafka. Bugs:

[jira] [Commented] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14103346#comment-14103346 ] Dong Lin commented on KAFKA-1601: - Updated reviewboard

[jira] [Updated] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1601: Attachment: KAFKA-1601_2014-08-19_21:10:12.patch ConsoleConsumer/SimpleConsumerPerformance should be

Re: Review Request 24856: Patch for KAFKA-1601

2014-08-19 Thread Dong Lin
On Aug. 20, 2014, 1:31 a.m., Joel Koshy wrote: core/src/main/scala/kafka/consumer/ConsumerTransactionBuffer.scala, line 7 https://reviews.apache.org/r/24856/diff/1/?file=664458#file664458line7 We should probably just grab this from TxRequestTypes in the api package for

[jira] [Updated] (KAFKA-1604) System Test for Transaction Management

2014-08-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1604: Attachment: (was: KAFKA-1604_2014-08-19_17:28:19.patch) System Test for Transaction Management

kafka TestUtils choosePort NoSuchMethodError

2014-08-19 Thread Parin Jogani
I am trying to create unit test case for Kafka with a simple call Properties props =TestUtils.createBrokerConfig(1, TestUtils.choosePort(), true); It fails on java.lang.NoSuchMethodError: scala.Predef$.intWrapper(I)Lscala/runtime/RichInt; at