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

[ https://issues.apache.org/jira/browse/KAFKA-1531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14063532#comment-14063532 ] Jun Rao commented on KAFKA-1531: Thanks for the patch. Do you want to include the changes

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

[ https://issues.apache.org/jira/browse/KAFKA-1531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ https://issues.apache.org/jira/browse/KAFKA-1531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

--- 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

> On July 15, 2014, 5:51 p.m., Guozhang Wang wrote: > > core/src/main/scala/kafka/server/ReplicaManager.scala, line 484 > > > > > > I am wondering if this function will introduce more lock contention on > > leaderIsrU

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

[ 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

[ https://issues.apache.org/jira/browse/KAFKA-1112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14063604#comment-14063604 ] Jun Rao commented on KAFKA-1112: This seems to happen on a clean restart (the following lo

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

[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14063708#comment-14063708 ] Jun Rao commented on KAFKA-1414: Thanks for the patch. A few comments. 20. KafkaServer an

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

[ 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

[ https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

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 Type:

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

[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14063733#comment-14063733 ] Anton Karamanov commented on KAFKA-1414: 21.3 There were similar logging at {{load

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

[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14063733#comment-14063733 ] Anton Karamanov edited comment on KAFKA-1414 at 7/16/14 5:10 PM: ---

Build failed in Jenkins: Kafka-trunk #224

See Changes: [jay.kreps] KAFKA-1512 Add per-ip connection limits. -- [...truncated 1877 lines...] kafka.integration.PrimitiveApiTest > testConsumerEmptyTopic FAILED java.net.BindException: Addres

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

[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14063742#comment-14063742 ] Jay Kreps commented on KAFKA-1414: -- Great patch! I second Jun's comments. Is there a wa

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

[ https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14063745#comment-14063745 ] Joe Stein commented on KAFKA-1180: -- if you could please that would be great, sorry I am s

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

[ 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

[ 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

[ 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-1541) Add transactional request definitions to clients package

[ https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14063764#comment-14063764 ] Joel Koshy commented on KAFKA-1541: --- Same here: https://cwiki.apache.org/confluence/dis

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

[ https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14063763#comment-14063763 ] Joel Koshy commented on KAFKA-1524: --- Can you use the patch review tool to submit? https:

Re: Review Request 23474: Patch for KAFKA-1483

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23474/ --- (Updated July 16, 2014, 6:07 p.m.) Review request for kafka. Bugs: KAFKA-1483

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

[ 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 Par

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

[ https://issues.apache.org/jira/browse/KAFKA-1483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14063829#comment-14063829 ] Sriharsha Chintalapani commented on KAFKA-1483: --- Updated reviewboard https:/

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

[ 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] [Comment Edited] (KAFKA-1414) Speedup broker startup after hard reset

[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14063870#comment-14063870 ] Anton Karamanov edited comment on KAFKA-1414 at 7/16/14 6:37 PM: ---

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

[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14063886#comment-14063886 ] Anton Karamanov edited comment on KAFKA-1414 at 7/16/14 6:43 PM: ---

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

[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ 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_TopicMetadataResponse.patch patch > return a

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

[ 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 h

Re: [DISCUSS] Kafka Security Specific Features

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 S

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

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

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

[ 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

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23566/ --- Review request for kafka. Bugs: KAFKA-1430 https://issues.apache.org/jira/b

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

[ https://issues.apache.org/jira/browse/KAFKA-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14064108#comment-14064108 ] Guozhang Wang commented on KAFKA-1430: -- Created reviewboard https://reviews.apache.or

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

[ 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: K

Re: [DISCUSS] Kafka Security Specific Features

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 wrote: > 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 (

Review Request 23567: Patch for KAFKA-1522

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23567/ --- Review request for kafka. Bugs: KAFKA-1522 https://issues.apache.org/jira/b

Review Request 23568: Patch for KAFKA-1523

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23568/ --- Review request for kafka. Bugs: KAFKA-1523 https://issues.apache.org/jira/b

Review Request 23569: Patch for KAFKA-1525

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23569/ --- Review request for kafka. Bugs: KAFKA-1525 https://issues.apache.org/jira/b

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

[ https://issues.apache.org/jira/browse/KAFKA-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14064128#comment-14064128 ] Dong Lin commented on KAFKA-1523: - Created reviewboard https://reviews.apache.org/r/23568/

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

[ 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

[ https://issues.apache.org/jira/browse/KAFKA-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14064129#comment-14064129 ] Dong Lin commented on KAFKA-1525: - Created reviewboard https://reviews.apache.org/r/23569/

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

[ https://issues.apache.org/jira/browse/KAFKA-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14064127#comment-14064127 ] Dong Lin commented on KAFKA-1522: - Created reviewboard https://reviews.apache.org/r/23567/

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

[ 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

[ 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] [Created] (KAFKA-1542) normal IOException in the new producer is logged as ERROR

Jun Rao created KAFKA-1542: -- Summary: normal IOException in the new producer is logged as ERROR Key: KAFKA-1542 URL: https://issues.apache.org/jira/browse/KAFKA-1542 Project: Kafka Issue Type: Bug

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

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1535: - Attachment: (was: KAFKA-1535__return_all_live_brokers_in_TopicMetadataResponse.patch) > retu

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

[ 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 liv

[jira] [Issue Comment Deleted] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1535: - Comment: was deleted (was: patch) > return all live brokers in TopicMetadataResponse > -

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

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14064158#comment-14064158 ] nicu marasoiu commented on KAFKA-1535: -- I will also try to find a kafka dev guide and

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

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14064186#comment-14064186 ] Jay Kreps commented on KAFKA-1535: -- Hey Nicu, this looks good to me. Did you do any testi

Re: [DISCUSS] Kafka Security Specific Features

Pramod, I presented secure kafka configuration and usage at last meet up. So hope this video recording would 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 wrote: > Hello Joe

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

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

Interested in contributing to Kafka?

Hey All, A number of people have been submitting really nice patches recently. If you are interested in contributing and are looking for something to work on, or if you are contributing and are interested in ramping up to be a committer on the project, please let us know--we are happy to help you

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

[ 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

--- 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

[ https://issues.apache.org/jira/browse/KAFKA-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14064244#comment-14064244 ] Jun Rao commented on KAFKA-1542: Also, it would be useful to log the remote ip that caused

Re: Review Request 23516: Patch for KAFKA-1462

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23516/#review47940 --- clients/src/main/java/org/apache/kafka/common/Cluster.java

Re: Review Request 23521: Fix KAFKA-1533

--- 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 <

Re: Review Request 23521: Fix KAFKA-1533

> On July 16, 2014, 11:25 p.m., Jun Rao wrote: > > clients/src/main/java/org/apache/kafka/clients/NetworkClient.java, lines > > 360-361 > > > > > > If a node can be connected, but is not connected yet, will the metada

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

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23593/ --- Review request for kafka. Bugs: KAFKA-1533 https://issues.apache.org/jira/b

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

[ 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

[ https://issues.apache.org/jira/browse/KAFKA-1533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14064338#comment-14064338 ] Guozhang Wang commented on KAFKA-1533: -- Created reviewboard https://reviews.apache.or

Review Request 23594: Fix KAFKA-1430

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23594/ --- Review request for kafka. Bugs: KAFKA-1430 https://issues.apache.org/jira/b

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

[ 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: K

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

[ https://issues.apache.org/jira/browse/KAFKA-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14064355#comment-14064355 ] Guozhang Wang commented on KAFKA-1430: -- Created reviewboard https://reviews.apache.or

Re: Interested in contributing to Kafka?

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? Jarcec

Re: Interested in contributing to Kafka?

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 i

Re: Interested in contributing to Kafka?

Hi Jay, I don't have a lot of experience patching kafka, but I would really like to help starting with some minor tasks. Thanks. On Wed, Jul 16, 2014 at 3:09 PM, Jay Kreps wrote: > Hey All, > > A number of people have been submitting really nice patches recently. > > If you are interested in con

Re: [DISCUSS] Kafka Security Specific Features

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 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. > > > > On Wed, J

Re: [DISCUSS] Kafka Security Specific Features

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 instal

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

[ https://issues.apache.org/jira/browse/KAFKA-42?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14064470#comment-14064470 ] sungjubong commented on KAFKA-42: - Created reviewboard against branch origin/trunk > Suppo

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

[ 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?

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 Security

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

[ https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14063745#comment-14063745 ] Joe Stein edited comment on KAFKA-1180 at 7/17/14 2:06 AM: --- Yes

Question about ConsoleConsumer

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

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

[ https://issues.apache.org/jira/browse/KAFKA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ https://issues.apache.org/jira/browse/KAFKA-328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14064490#comment-14064490 ] BalajiSeshadri commented on KAFKA-328: -- Please assign to me i will work on the fix. >

Re: Question about ConsoleConsumer

auto.offset.reset is only when there is not an already established offset to consume from or an offset that no longer exists (and is invalid) in the case of truncated logs or compaction). You can force this behavior by deleting the znode /*** Joe Stein Fo

RE: Question about ConsoleConsumer

Hi Joe, Thanks for your answer, seems I know what's its purpose. Thanks a lot. Jerry -Original Message- From: Joe Stein [mailto:joe.st...@stealth.ly] Sent: Thursday, July 17, 2014 10:15 AM To: dev@kafka.apache.org Cc: us...@kafka.apache.org Subject: Re: Question about ConsoleConsumer a

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

[ 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

> On July 16, 2014, 11:09 p.m., Guozhang Wang wrote: > > clients/src/main/java/org/apache/kafka/common/Cluster.java, line 18 > > > > > > Do we ever want to use * in imports? IDE did the optimization since there are too

Re: Review Request 23516: Patch for KAFKA-1462

--- 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: KAFKA-1462

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

[ https://issues.apache.org/jira/browse/KAFKA-1462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14064567#comment-14064567 ] Jun Rao commented on KAFKA-1462: Updated reviewboard https://reviews.apache.org/r/23516/

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

[ 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