[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: freebie.patch I would also like to throw in that little [patch|^freebie.patch]. I

[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-rev2.fixed.patch > Speedup broker startup after hard reset > -

[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=14066027#comment-14066027 ] Anton Karamanov edited comment on KAFKA-1414 at 7/18/14 6:40 AM: ---

[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: (was: KAFKA-1414-rev2.fixed.patch) > Speedup broker startup after hard reset

[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-rev2.fixed.patch Small fix: directory unlocking should have been perfo

[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=14066031#comment-14066031 ] Anton Karamanov edited comment on KAFKA-1414 at 7/18/14 5:09 AM: ---

[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=14066031#comment-14066031 ] Anton Karamanov commented on KAFKA-1414: [~jkreps], I've never actually encountere

[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=14066027#comment-14066027 ] Anton Karamanov edited comment on KAFKA-1414 at 7/18/14 5:05 AM: ---

[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-rev2.patch Thanks for the review. Here's updated [^KAFKA-1414-rev2.pa

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

[ https://issues.apache.org/jira/browse/KAFKA-1192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14066021#comment-14066021 ] Manikumar Reddy commented on KAFKA-1192: Some points 1. Users need to provide cus

[jira] [Issue Comment Deleted] (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: Comment: was deleted (was: python kafka-patch-review.py incorrectly involves needed changes... Need to do

[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_2014-07-17_20:12:55.patch > Implement transaction manager module > -

Re: Review Request 23568: Patch for KAFKA-1523

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23568/ --- (Updated July 18, 2014, 3:12 a.m.) Review request for kafka. Bugs: KAFKA-1523

[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=14065961#comment-14065961 ] Dong Lin commented on KAFKA-1522: - Updated 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_2014-07-17_20:12:06.patch > Transactional messaging request/response definitions > -

Re: Review Request 23567: Patch for KAFKA-1522

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23567/ --- (Updated July 18, 2014, 3:12 a.m.) Review request for kafka. Bugs: KAFKA-1522

[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=14065963#comment-14065963 ] Dong Lin commented on KAFKA-1523: - Updated reviewboard https://reviews.apache.org/r/23568/

[jira] [Updated] (KAFKA-1451) Broker stuck due to leader election race

[ https://issues.apache.org/jira/browse/KAFKA-1451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1451: - Labels: newbie (was: ) > Broker stuck due to leader election race > ---

[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=14065956#comment-14065956 ] Neha Narkhede commented on KAFKA-328: - Hey [~balajisn], it will be good to see if we al

[jira] [Updated] (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 ] Neha Narkhede updated KAFKA-1192: - Component/s: tools > Enable DumpLogSegments tool to deserialize messages > --

[jira] [Updated] (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:all-tabpanel ] Neha Narkhede updated KAFKA-328: Assignee: BalajiSeshadri > Write unit test for kafka server startup and shutdown API >

[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: (was: KAFKA-1523.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: (was: KAFKA-1523_2014-07-17_20:01:21.patch) > Implement transaction manager module > --

[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: (was: KAFKA-1523.patch) > Implement transaction manager module > --

[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: (was: KAFKA-1522_2014-07-17_19:38:36.patch) > Transactional messaging request/response defi

[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-1523.patch > Transactional messaging request/response definitions > -

[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=14065952#comment-14065952 ] Dong Lin commented on KAFKA-1523: - python kafka-patch-review.py incorrectly involves neede

[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=14065948#comment-14065948 ] Dong Lin commented on KAFKA-1523: - Updated reviewboard https://reviews.apache.org/r/23568/

[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_2014-07-17_20:01:21.patch > Implement transaction manager module > -

Re: Review Request 23568: Patch for KAFKA-1523

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23568/ --- (Updated July 18, 2014, 3:01 a.m.) Review request for kafka. Bugs: KAFKA-1523

[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: (was: KAFKA-1523_2014-07-17_19:26:34.patch) > Implement transaction manager module > --

Re: Review Request 23521: Fix KAFKA-1533

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23521/#review48102 --- clients/src/main/java/org/apache/kafka/clients/NetworkClient.java <

[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: (was: KAFKA-1522_2014-07-17_19:30:29.patch) > Transactional messaging request/response defi

[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_2014-07-17_19:38:36.patch > Transactional messaging request/response definitions > -

[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=14065926#comment-14065926 ] Dong Lin commented on KAFKA-1522: - Updated reviewboard https://reviews.apache.org/r/23567/

Re: Review Request 23567: Patch for KAFKA-1522

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23567/ --- (Updated July 18, 2014, 2:38 a.m.) Review request for kafka. Bugs: KAFKA-1522

Re: Review Request 23567: Patch for KAFKA-1522

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23567/ --- (Updated July 18, 2014, 2:37 a.m.) Review request for kafka. Bugs: KAFKA-1522

Re: Review Request 23567: Patch for KAFKA-1522

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23567/ --- (Updated July 18, 2014, 2:36 a.m.) Review request for kafka. Bugs: KAFKA-1522

Re: Review Request 23567: Patch for KAFKA-1522

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23567/ --- (Updated July 18, 2014, 2:36 a.m.) Review request for kafka. Bugs: KAFKA-1522

Re: Review Request 23567: Patch for KAFKA-1522

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23567/ --- (Updated July 18, 2014, 2:36 a.m.) Review request for kafka. Bugs: KAFKA-1522

[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_2014-07-17_19:30:29.patch > Transactional messaging request/response definitions > -

[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=14065919#comment-14065919 ] Dong Lin commented on KAFKA-1522: - Updated 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_2014-07-17_19:30:39.patch > Transactional messaging request/response definitions > -

[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: (was: KAFKA-1522.patch) > Transactional messaging request/response definitions > --

[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: (was: KAFKA-1522_2014-07-17_19:30:39.patch) > Transactional messaging request/response defi

[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=14065918#comment-14065918 ] Dong Lin commented on KAFKA-1522: - Updated reviewboard against branch origin/transactiona

Re: Review Request 23567: Patch for KAFKA-1522

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23567/ --- (Updated July 18, 2014, 2:30 a.m.) Review request for kafka. Bugs: KAFKA-1522

Re: Review Request 23567: Patch for KAFKA-1522

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23567/#review48098 --- core/src/main/scala/kafka/api/TransactionRequest.scala

[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=14065912#comment-14065912 ] Dong Lin commented on KAFKA-1523: - Updated reviewboard https://reviews.apache.org/r/23568/

[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_2014-07-17_19:26:34.patch > Implement transaction manager module > -

Re: Review Request 23568: Patch for KAFKA-1523

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23568/ --- (Updated July 18, 2014, 2:26 a.m.) Review request for kafka. Bugs: KAFKA-1523

Build failed in Jenkins: Kafka-trunk #226

See Changes: [junrao] kafka-1462; Add new request and response formats for the new consumer and coordinator communication; patched by Jun Rao; reviewed by Guozhang Wang and Jay Kreps -- [...truncate

[jira] [Resolved] (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 resolved KAFKA-1462. Resolution: Fixed Fix Version/s: (was: 0.9.0) 0.8.2 Thanks for the reviews. C

Re: Review Request 23516: Patch for KAFKA-1462

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23516/#review48092 --- Ship it! Ship It! - Jay Kreps On July 17, 2014, 4:39 a.m., Jun R

[jira] [Commented] (KAFKA-1546) Automate replica lag tuning

[ https://issues.apache.org/jira/browse/KAFKA-1546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14065806#comment-14065806 ] Jay Kreps commented on KAFKA-1546: -- I think this is actually a really important thing to

Build failed in Jenkins: Kafka-trunk #225

See Changes: [jay.kreps] KAFKA-1535 Have the metadata response contain all alive brokers rather than just the ones needed for the given topics. -- [...truncated 503 lines...] org.apache.kafka.common.

[jira] [Resolved] (KAFKA-183) Expose offset vector to the consumer

[ https://issues.apache.org/jira/browse/KAFKA-183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-183. - Resolution: Fixed This is being done in the new consumer. > Expose offset vector to the consumer > --

[jira] [Updated] (KAFKA-1476) Get a list of consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BalajiSeshadri updated KAFKA-1476: -- Attachment: (was: ConsumerGroupLister.scala) > Get a list of consumer groups >

[jira] [Updated] (KAFKA-1476) Get a list of consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BalajiSeshadri updated KAFKA-1476: -- Status: Patch Available (was: Open) Created ConsumerGroupLister class that lists all ConsumerG

[jira] [Updated] (KAFKA-1476) Get a list of consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BalajiSeshadri updated KAFKA-1476: -- Attachment: KAFKA-1476.patch ConsumerGroupLister.scala > Get a list of consumer

[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 ] Jay Kreps updated KAFKA-1535: - Resolution: Fixed Assignee: Jay Kreps Status: Resolved (was: Patch Available) Patch looks

[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=14065721#comment-14065721 ] Jay Kreps commented on KAFKA-1414: -- Hey [~aozeritsky], any before/after perf numbers for

[jira] [Commented] (KAFKA-1070) Auto-assign node id

[ https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14065702#comment-14065702 ] Jay Kreps commented on KAFKA-1070: -- Hey [~harsha_ch], that is a great point. I'd like to

[jira] [Commented] (KAFKA-1070) Auto-assign node id

[ https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14065670#comment-14065670 ] Sriharsha Chintalapani commented on KAFKA-1070: --- [~jkreps] [~nehanarkhede] I

Re: [DISCUSS] Kafka Security Specific Features

Correct, I don't see any exceptions when i turn off security. Consumer is able to consume the message. I still see warning for topic property. [2014-07-17 18:04:38,360] WARN Property topic is not valid (kafka.utils.VerifiableProperties) On Thu, Jul 17, 2014 at 5:49 PM, Rajasekar Elango wrot

[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=14065646#comment-14065646 ] Jay Kreps commented on KAFKA-1535: -- Our current model of nodes is that they are permanent

Re: Review Request 23516: Patch for KAFKA-1462

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23516/#review48071 --- I am not sure why we need to remove correlationId from the ReuqestOr

[jira] [Resolved] (KAFKA-169) Layering violations in Kafka code

[ https://issues.apache.org/jira/browse/KAFKA-169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-169. - Resolution: Won't Fix > Layering violations in Kafka code > - > >

Re: [DISCUSS] Kafka Security Specific Features

Can you try with turning off security to check if this error happens only on secure mode? Thanks, Raja. On Thu, Jul 17, 2014 at 3:51 PM, Pramod Deshmukh wrote: > Thanks Raja, it was helpful > > Now I am able to start zookeeper and broker in secure mode ready for SSL > handshake. I get *java.

[jira] [Commented] (KAFKA-1543) Changing replication factor

[ https://issues.apache.org/jira/browse/KAFKA-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14065616#comment-14065616 ] Jay Kreps commented on KAFKA-1543: -- I wonder if it would make more sense to have the alte

Re: Interested in contributing to Kafka?

Hey Neha, I like all these ideas. I think people have been doing a good job with the newbie label, which is great, we should keep doing that. I think pairing people up is a great idea. The trick is actually figuring out who has an interest in becoming a committer and would like a pair, and who i

[jira] [Commented] (KAFKA-1476) Get a list of consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14065534#comment-14065534 ] BalajiSeshadri commented on KAFKA-1476: --- I'm working on this JIRA ticket to create t

[jira] [Created] (KAFKA-1548) Refactor the "replica_id" in requests

Guozhang Wang created KAFKA-1548: Summary: Refactor the "replica_id" in requests Key: KAFKA-1548 URL: https://issues.apache.org/jira/browse/KAFKA-1548 Project: Kafka Issue Type: Bug

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? > > Jun Rao wrote: > IDE did the optimiz

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

[ https://issues.apache.org/jira/browse/KAFKA-1483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede reassigned KAFKA-1483: Assignee: Neha Narkhede (was: Sriharsha Chintalapani) Assigning to myself for review > Sp

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

[ https://issues.apache.org/jira/browse/KAFKA-687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy reassigned KAFKA-687: Assignee: Joel Koshy (was: Sriharsha Chintalapani) > Rebalance algorithm should consider partitions

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

[ https://issues.apache.org/jira/browse/KAFKA-687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14065457#comment-14065457 ] Joel Koshy commented on KAFKA-687: -- I ended up abandoning the earlier approach I was think

Re: [DISCUSS] Kafka Security Specific Features

Thanks Raja, it was helpful Now I am able to start zookeeper and broker in secure mode ready for SSL handshake. I get *java.lang.OutOfMemoryError: Java heap space* on producer. I using the default configuration and keystore. Is there anything missing *Start broker:* *bin/kafka-server-start.sh c

Re: Review Request 23655: Provide alternate (round-robin-style) rebalance algorithms.

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23655/#review48043 --- core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala

Re: Review Request 23655: Provide alternate (round-robin-style) rebalance algorithms.

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23655/ --- (Updated July 17, 2014, 7:50 p.m.) Review request for kafka. Bugs: KAFKA-687

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

[ https://issues.apache.org/jira/browse/KAFKA-687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14065446#comment-14065446 ] Joel Koshy commented on KAFKA-687: -- Created reviewboard https://reviews.apache.org/r/23655

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

[ 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.patch > Rebalance algorithm should consider partitions from all topics > ---

Review Request 23655: Provide alternate (round-robin-style) rebalance algorithms.

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

[jira] [Comment Edited] (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=14065424#comment-14065424 ] nicu marasoiu edited comment on KAFKA-1535 at 7/17/14 7:43 PM: -

[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=14065435#comment-14065435 ] nicu marasoiu commented on KAFKA-1535: -- the other strange thing: in the metadataCache

[jira] [Comment Edited] (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=14065424#comment-14065424 ] nicu marasoiu edited comment on KAFKA-1535 at 7/17/14 7:32 PM: -

[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=14065424#comment-14065424 ] nicu marasoiu commented on KAFKA-1535: -- updated patch, tests fine, one question thou

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

[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] Subscription: outstanding kafka patches

Issue Subscription Filter: outstanding kafka patches (109 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-1543 Changing replication factor https://issues.apache.org/jira/browse/KAFKA-1543 KAFKA-1541 Add transactional request def

[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 > return all live

[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_TopicMetadataResponse1.patch) > ret

[jira] [Resolved] (KAFKA-1479) Logs filling up while Kafka ReplicaFetcherThread tries to retrieve partition info for deleted topics

[ https://issues.apache.org/jira/browse/KAFKA-1479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1479. -- Resolution: Not a Problem Assignee: (was: Jay Kreps) This is not a problem once delet

[jira] [Reopened] (KAFKA-1377) transient unit test failure in LogOffsetTest

[ https://issues.apache.org/jira/browse/KAFKA-1377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede reopened KAFKA-1377: -- [~junrao], reopening this as per [~omkreddy]'s observation > transient unit test failure in LogOff

[jira] [Commented] (KAFKA-1547) maven sources jar still empty

[ https://issues.apache.org/jira/browse/KAFKA-1547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14065320#comment-14065320 ] lee mighdoll commented on KAFKA-1547: - ah, looks like a dup of KAFKA-1502 > maven sou

[jira] [Created] (KAFKA-1547) maven sources jar still empty

lee mighdoll created KAFKA-1547: --- Summary: maven sources jar still empty Key: KAFKA-1547 URL: https://issues.apache.org/jira/browse/KAFKA-1547 Project: Kafka Issue Type: Bug Componen

[jira] [Created] (KAFKA-1546) Automate replica lag tuning

Neha Narkhede created KAFKA-1546: Summary: Automate replica lag tuning Key: KAFKA-1546 URL: https://issues.apache.org/jira/browse/KAFKA-1546 Project: Kafka Issue Type: Improvement C

[jira] [Created] (KAFKA-1545) java.net.InetAddress.getLocalHost in KafkaHealthcheck.register may fail on some irregular hostnames

Guozhang Wang created KAFKA-1545: Summary: java.net.InetAddress.getLocalHost in KafkaHealthcheck.register may fail on some irregular hostnames Key: KAFKA-1545 URL: https://issues.apache.org/jira/browse/KAFKA-1545

Re: Review Request 23474: Patch for KAFKA-1483

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23474/#review48028 --- Ship it! - Guozhang Wang On July 16, 2014, 6:07 p.m., Sriharsha C

[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=14065194#comment-14065194 ] Raul Castro Fernandez commented on KAFKA-1524: -- Created reviewboard https://r

  1   2   >