[jira] [Commented] (KAFKA-1531) zookeeper.connection.timeout.ms is set to 10000000 in configuration file in Kafka tarball

2014-07-16 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14063541#comment-14063541 ] Manikumar Reddy commented on KAFKA-1531: Previous patch I tried to update all the

[jira] [Comment Edited] (KAFKA-1531) zookeeper.connection.timeout.ms is set to 10000000 in configuration file in Kafka tarball

2014-07-16 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14063541#comment-14063541 ] Manikumar Reddy edited comment on KAFKA-1531 at 7/16/14 2:35 PM:

Re: Review Request 23474: Patch for KAFKA-1483

2014-07-16 Thread Jun Rao
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23474/#review47884 --- core/src/main/scala/kafka/server/ReplicaManager.scala

Re: Review Request 23474: Patch for KAFKA-1483

2014-07-16 Thread Jun Rao
On July 15, 2014, 5:51 p.m., Guozhang Wang wrote: core/src/main/scala/kafka/server/ReplicaManager.scala, line 484 https://reviews.apache.org/r/23474/diff/1/?file=631878#file631878line484 I am wondering if this function will introduce more lock contention on leaderIsrUpdateLock?

[jira] [Updated] (KAFKA-1531) zookeeper.connection.timeout.ms is set to 10000000 in configuration file in Kafka tarball

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

[jira] [Commented] (KAFKA-1112) broker can not start itself after kafka is killed with -9

2014-07-16 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14063604#comment-14063604 ] Jun Rao commented on KAFKA-1112: This seems to happen on a clean restart (the following

[jira] [Commented] (KAFKA-1414) Speedup broker startup after hard reset

2014-07-16 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14063708#comment-14063708 ] Jun Rao commented on KAFKA-1414: Thanks for the patch. A few comments. 20. KafkaServer

[jira] [Resolved] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-07-16 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1512. -- Resolution: Fixed Committed. Limit the maximum number of connections per ip address

[jira] [Commented] (KAFKA-1180) WhiteList topic filter gets a NullPointerException on complex Regex

2014-07-16 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14063713#comment-14063713 ] Jun Rao commented on KAFKA-1180: Joel Koshy, Joe Stein, Do you want to review and commit

[jira] [Created] (KAFKA-1541) Add transactional request definitions to clients package

2014-07-16 Thread Joel Koshy (JIRA)
Joel Koshy created KAFKA-1541: - Summary: Add transactional request definitions to clients package Key: KAFKA-1541 URL: https://issues.apache.org/jira/browse/KAFKA-1541 Project: Kafka Issue

[jira] [Commented] (KAFKA-1414) Speedup broker startup after hard reset

2014-07-16 Thread Anton Karamanov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14063733#comment-14063733 ] Anton Karamanov commented on KAFKA-1414: 21.3 There were similar logging at

[jira] [Commented] (KAFKA-1414) Speedup broker startup after hard reset

2014-07-16 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14063742#comment-14063742 ] Jay Kreps commented on KAFKA-1414: -- Great patch! I second Jun's comments. Is there a

[jira] [Commented] (KAFKA-1180) WhiteList topic filter gets a NullPointerException on complex Regex

2014-07-16 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14063745#comment-14063745 ] Joe Stein commented on KAFKA-1180: -- if you could please that would be great, sorry I am

[jira] [Updated] (KAFKA-1541) Add transactional request definitions to clients package

2014-07-16 Thread Raul Castro Fernandez (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raul Castro Fernandez updated KAFKA-1541: - Attachment: KAFKA-1541.patch Add transactional request definitions to clients

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

2014-07-16 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.patch Producer performance tool should have an option to

[jira] [Updated] (KAFKA-1524) Implement transactional producer

2014-07-16 Thread Raul Castro Fernandez (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raul Castro Fernandez updated KAFKA-1524: - Attachment: KAFKA-1524.patch Implement transactional producer

[jira] [Commented] (KAFKA-1524) Implement transactional producer

2014-07-16 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14063763#comment-14063763 ] Joel Koshy commented on KAFKA-1524: --- Can you use the patch review tool to submit?

[jira] [Updated] (KAFKA-1483) Split Brain about Leader Partitions

2014-07-16 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1483: -- Attachment: KAFKA-1483_2014-07-16_11:07:44.patch Split Brain about Leader

[jira] [Updated] (KAFKA-1414) Speedup broker startup after hard reset

2014-07-16 Thread Anton Karamanov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Karamanov updated KAFKA-1414: --- Attachment: KAFKA-1414-rev1.patch I've updated the patch (and corresponding GitHub issue):

[jira] [Commented] (KAFKA-1414) Speedup broker startup after hard reset

2014-07-16 Thread Anton Karamanov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14063886#comment-14063886 ] Anton Karamanov commented on KAFKA-1414: I like the idea of using more informative

[jira] [Updated] (KAFKA-1535) return all live brokers in TopicMetadataResponse

2014-07-16 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1535: - Status: Patch Available (was: Open) I attached a patch generated with Idea. Please let me know

Re: [DISCUSS] Kafka Security Specific Features

2014-07-16 Thread Joe Stein
That is a very old branch. Here is a more up to date one https://github.com/stealthly/kafka/tree/v0.8.2_KAFKA-1477 (needs to be updated to latest trunk might have a chance to-do that next week). You should be using gradle now as per the README. /*** Joe

[jira] [Updated] (KAFKA-1541) Add transactional request definitions to clients package

2014-07-16 Thread Raul Castro Fernandez (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raul Castro Fernandez updated KAFKA-1541: - Attachment: KAFKA-1541.patch Add transactional request definitions to clients

Review Request 23566: Fix KAFKA-1430

2014-07-16 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23566/ --- Review request for kafka. Bugs: KAFKA-1430

[jira] [Commented] (KAFKA-1430) Purgatory redesign

2014-07-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14064108#comment-14064108 ] Guozhang Wang commented on KAFKA-1430: -- Created reviewboard

[jira] [Updated] (KAFKA-1430) Purgatory redesign

2014-07-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1430: - Attachment: KAFKA-1430.patch Purgatory redesign -- Key:

Re: [DISCUSS] Kafka Security Specific Features

2014-07-16 Thread Pramod Deshmukh
Thanks Joe, This branch works. I was able to proceed. I still had to set scala version to 2.9.2 in kafka-run-class.sh. On Wed, Jul 16, 2014 at 3:57 PM, Joe Stein joe.st...@stealth.ly wrote: That is a very old branch. Here is a more up to date one

Review Request 23567: Patch for KAFKA-1522

2014-07-16 Thread Dong Lin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23567/ --- Review request for kafka. Bugs: KAFKA-1522

Review Request 23568: Patch for KAFKA-1523

2014-07-16 Thread Dong Lin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23568/ --- Review request for kafka. Bugs: KAFKA-1523

Review Request 23569: Patch for KAFKA-1525

2014-07-16 Thread Dong Lin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23569/ --- Review request for kafka. Bugs: KAFKA-1525

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

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

[jira] [Updated] (KAFKA-1525) DumpLogSegments should print transaction IDs

2014-07-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1525: Attachment: KAFKA-1525.patch DumpLogSegments should print transaction IDs

[jira] [Commented] (KAFKA-1525) DumpLogSegments should print transaction IDs

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

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

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

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

2014-07-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1522: Attachment: KAFKA-1522.patch Transactional messaging request/response definitions

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

2014-07-16 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: Attachment: KAFKA-1523.patch Implement transaction manager module

[jira] [Updated] (KAFKA-1535) return all live brokers in TopicMetadataResponse

2014-07-16 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1535: - Attachment: KAFKA-1535__return_all_live_brokers_in_TopicMetadataResponse1.patch return all

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

2014-07-16 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14064186#comment-14064186 ] Jay Kreps commented on KAFKA-1535: -- Hey Nicu, this looks good to me. Did you do any

Re: [DISCUSS] Kafka Security Specific Features

2014-07-16 Thread Rajasekar Elango
Pramod, I presented secure kafka configuration and usage at last meet up. So hope this video recording http://www.ustream.tv/recorded/48396701would help. You can skip to about 59 min to jump to security talk. Thanks, Raja. On Wed, Jul 16, 2014 at 5:57 PM, Pramod Deshmukh dpram...@gmail.com

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

2014-07-16 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14064211#comment-14064211 ] nicu marasoiu commented on KAFKA-1535: -- Hi Jay, Great:) For the tests, I just run

[jira] [Updated] (KAFKA-1542) normal IOException in the new producer is logged as ERROR

2014-07-16 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1542: --- Labels: newbie (was: ) normal IOException in the new producer is logged as ERROR

Re: Review Request 23516: Patch for KAFKA-1462

2014-07-16 Thread Jay Kreps
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23516/#review47954 --- clients/src/main/java/org/apache/kafka/common/Cluster.java

[jira] [Commented] (KAFKA-1542) normal IOException in the new producer is logged as ERROR

2014-07-16 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14064244#comment-14064244 ] Jun Rao commented on KAFKA-1542: Also, it would be useful to log the remote ip that caused

Re: Review Request 23521: Fix KAFKA-1533

2014-07-16 Thread Jun Rao
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23521/#review47959 --- clients/src/main/java/org/apache/kafka/clients/NetworkClient.java

Review Request 23593: Fix KAFKA-1533: Address Jun's comments

2014-07-16 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23593/ --- Review request for kafka. Bugs: KAFKA-1533

[jira] [Updated] (KAFKA-1533) transient unit test failure in ProducerFailureHandlingTest

2014-07-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1533: - Attachment: KAFKA-1533.patch transient unit test failure in ProducerFailureHandlingTest

[jira] [Commented] (KAFKA-1533) transient unit test failure in ProducerFailureHandlingTest

2014-07-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14064338#comment-14064338 ] Guozhang Wang commented on KAFKA-1533: -- Created reviewboard

Review Request 23594: Fix KAFKA-1430

2014-07-16 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23594/ --- Review request for kafka. Bugs: KAFKA-1430

[jira] [Updated] (KAFKA-1430) Purgatory redesign

2014-07-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1430: - Attachment: KAFKA-1430.patch Purgatory redesign -- Key:

[jira] [Commented] (KAFKA-1430) Purgatory redesign

2014-07-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14064355#comment-14064355 ] Guozhang Wang commented on KAFKA-1430: -- Created reviewboard

Re: Interested in contributing to Kafka?

2014-07-16 Thread Jarek Jarcec Cecho
I’m completely new to Kafka as well, but I would really like to contribute. On other projects we’re using label “newbie” to denote JIRA that is particularly suitable for someone completely new to the project. I’m wondering if Kafka uses similar mechanism to annotate “newbie” JIRAs/tasks?

Re: Interested in contributing to Kafka?

2014-07-16 Thread Alan Lee
I am a newbie as well and would be great if you can add a 'newbie' label to the Jira tickets. -Alan On 2014. 7. 17. 오전 8:26, Jarek Jarcec Cecho wrote: I’m completely new to Kafka as well, but I would really like to contribute. On other projects we’re using label “newbie” to denote JIRA that

Re: [DISCUSS] Kafka Security Specific Features

2014-07-16 Thread Pramod Deshmukh
Hello Joe, Is there a configuration or example to test Kafka security piece? Thanks, Pramod On Wed, Jul 16, 2014 at 5:20 PM, Pramod Deshmukh dpram...@gmail.com wrote: Thanks Joe, This branch works. I was able to proceed. I still had to set scala version to 2.9.2 in kafka-run-class.sh.

Re: [DISCUSS] Kafka Security Specific Features

2014-07-16 Thread Pramod Deshmukh
Thanks Joe for this, I cloned this branch and tried to run zookeeper but I get Error: Could not find or load main class org.apache.zookeeper.server.quorum.QuorumPeerMain I see scala version is still set to 2.8.0 if [ -z $SCALA_VERSION ]; then SCALA_VERSION=2.8.0 fi Then I

[jira] [Commented] (KAFKA-42) Support rebalancing the partitions with replication

2014-07-16 Thread sungjubong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-42?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14064470#comment-14064470 ] sungjubong commented on KAFKA-42: - Created reviewboard against branch origin/trunk

[jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication

2014-07-16 Thread sungjubong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-42?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sungjubong updated KAFKA-42: Attachment: KAFKA-42.patch Support rebalancing the partitions with replication

Re: Interested in contributing to Kafka?

2014-07-16 Thread Joe Stein
Here are the newbie labels in JIRA for open Kafka tickets https://issues.apache.org/jira/issues/?jql=project%20%3D%20KAFKA%20AND%20labels%20%3D%20newbie%20AND%20status%20%3D%20Open /*** Joe Stein Founder, Principal Consultant Big Data Open Source

[jira] [Comment Edited] (KAFKA-1180) WhiteList topic filter gets a NullPointerException on complex Regex

2014-07-16 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14063745#comment-14063745 ] Joe Stein edited comment on KAFKA-1180 at 7/17/14 2:06 AM: --- Yes

Question about ConsoleConsumer

2014-07-16 Thread Shao, Saisai
Hi folks, A newbie question when investigating ConsoleConsumer's code, When we use ConsoleConsumer by setting -from-beginning, we will set property as auto.offset.reset=smallest, which means moving the offset to the beginning of the data. But in the code, we still need to delete Zookeeper's

[jira] [Comment Edited] (KAFKA-1180) WhiteList topic filter gets a NullPointerException on complex Regex

2014-07-16 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14063745#comment-14063745 ] Joe Stein edited comment on KAFKA-1180 at 7/17/14 2:09 AM: --- Yes

[jira] [Commented] (KAFKA-328) Write unit test for kafka server startup and shutdown API

2014-07-16 Thread BalajiSeshadri (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14064490#comment-14064490 ] BalajiSeshadri commented on KAFKA-328: -- Please assign to me i will work on the fix.

[jira] [Assigned] (KAFKA-1192) Enable DumpLogSegments tool to deserialize messages

2014-07-16 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy reassigned KAFKA-1192: -- Assignee: Manikumar Reddy Enable DumpLogSegments tool to deserialize messages

Re: Review Request 23516: Patch for KAFKA-1462

2014-07-16 Thread Jun Rao
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23516/ --- (Updated July 17, 2014, 4:39 a.m.) Review request for kafka. Bugs:

[jira] [Updated] (KAFKA-1462) Add new request and response formats for the new consumer and coordinator communication

2014-07-16 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1462: --- Attachment: KAFKA-1462_2014-07-16_21:39:07.patch Add new request and response formats for the new consumer