[jira] [Commented] (KAFKA-1530) howto update continuously

[ https://issues.apache.org/jira/browse/KAFKA-1530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14064815#comment-14064815 ] Oleg Golovin commented on KAFKA-1530: - Thank you for mentioning the option "unclean.le

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

Alexey Ozeritskiy created KAFKA-1543: Summary: Changing replication factor Key: KAFKA-1543 URL: https://issues.apache.org/jira/browse/KAFKA-1543 Project: Kafka Issue Type: Improvement

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

[ https://issues.apache.org/jira/browse/KAFKA-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Ozeritskiy updated KAFKA-1543: - Attachment: can-change-replication.patch > Changing replication factor >

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

[ https://issues.apache.org/jira/browse/KAFKA-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Ozeritskiy updated KAFKA-1543: - Description: It is difficult to change replication factor by manual editing json config.

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

[ https://issues.apache.org/jira/browse/KAFKA-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Ozeritskiy updated KAFKA-1543: - Status: Patch Available (was: Open) > Changing replication factor >

[jira] [Created] (KAFKA-1544) LogCleaner may take a long time to shutdown

Jun Rao created KAFKA-1544: -- Summary: LogCleaner may take a long time to shutdown Key: KAFKA-1544 URL: https://issues.apache.org/jira/browse/KAFKA-1544 Project: Kafka Issue Type: Bug Compo

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

[ https://issues.apache.org/jira/browse/KAFKA-1451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14064976#comment-14064976 ] Kenny commented on KAFKA-1451: -- This can also be caused by restarting Kafka quickly after a s

[jira] [Commented] (KAFKA-1544) LogCleaner may take a long time to shutdown

[ https://issues.apache.org/jira/browse/KAFKA-1544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14064989#comment-14064989 ] Jun Rao commented on KAFKA-1544: One solution is to simply put the sleep in a loop. In eac

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] [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=14065034#comment-14065034 ] Jun Rao commented on KAFKA-1414: Thanks for patch v3. A few more comments. 30. No need to

Re: Review Request 23568: Patch for KAFKA-1523

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23568/#review48011 --- core/src/main/scala/kafka/server/KafkaApis.scala

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

[ https://issues.apache.org/jira/browse/KAFKA-1451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14065055#comment-14065055 ] Jun Rao commented on KAFKA-1451: Thanks for reporting this. Very interesting. That does so

[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

[jira] [Assigned] (KAFKA-1536) Change the status of the JIRA to "Patch Available" in the kafka-review-tool

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

Review Request 23641: Patch for KAFKA-1536

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

[jira] [Commented] (KAFKA-1536) Change the status of the JIRA to "Patch Available" in the kafka-review-tool

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

[jira] [Updated] (KAFKA-1536) Change the status of the JIRA to "Patch Available" in the kafka-review-tool

[ https://issues.apache.org/jira/browse/KAFKA-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1536: - Attachment: KAFKA-1536.patch > Change the status of the JIRA to "Patch Available" in the kafka-re

[jira] [Updated] (KAFKA-1536) Change the status of the JIRA to "Patch Available" in the kafka-review-tool

[ https://issues.apache.org/jira/browse/KAFKA-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1536: - Status: Patch Available (was: In Progress) > Change the status of the JIRA to "Patch Available"

[jira] [Comment Edited] (KAFKA-1536) Change the status of the JIRA to "Patch Available" in the kafka-review-tool

[ https://issues.apache.org/jira/browse/KAFKA-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14065123#comment-14065123 ] Neha Narkhede edited comment on KAFKA-1536 at 7/17/14 4:56 PM: -

Re: Review Request 23440: Patch for KAFKA-1536

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23440/#review48017 --- Other than the comment below, this patch looks great! kafka-patch-

[jira] [Commented] (KAFKA-1536) Change the status of the JIRA to "Patch Available" in the kafka-review-tool

[ https://issues.apache.org/jira/browse/KAFKA-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14065128#comment-14065128 ] Neha Narkhede commented on KAFKA-1536: -- [~omkreddy] Thanks a lot for improving our to

[jira] [Updated] (KAFKA-1538) TEST JIRA for KAFKA-1536

[ https://issues.apache.org/jira/browse/KAFKA-1538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1538: - Resolution: Invalid Status: Resolved (was: Patch Available) Closing this as the test suc

[jira] [Closed] (KAFKA-1538) TEST JIRA for KAFKA-1536

[ https://issues.apache.org/jira/browse/KAFKA-1538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-1538. > TEST JIRA for KAFKA-1536 > > > Key: KAFKA-1538 >

[jira] [Commented] (KAFKA-1059) Improve the patch review tool to use OAuth for JIRA access

[ https://issues.apache.org/jira/browse/KAFKA-1059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14065137#comment-14065137 ] Neha Narkhede commented on KAFKA-1059: -- hey [~omkreddy], thanks for proactively looki

[jira] [Updated] (KAFKA-1059) Improve the patch review tool to use OAuth for JIRA access

[ https://issues.apache.org/jira/browse/KAFKA-1059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1059: - Assignee: Manikumar Reddy > Improve the patch review tool to use OAuth for JIRA access >

[jira] [Updated] (KAFKA-1059) Improve the patch review tool to use OAuth for JIRA access

[ https://issues.apache.org/jira/browse/KAFKA-1059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1059: - Labels: newbie (was: ) > Improve the patch review tool to use OAuth for JIRA access > --

[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=14065142#comment-14065142 ] Neha Narkhede commented on KAFKA-1180: -- [~charmalloc] Is there any more work to be do

[jira] [Updated] (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:all-tabpanel ] Neha Narkhede updated KAFKA-1180: - Assignee: Joel Koshy (was: Neha Narkhede) > WhiteList topic filter gets a NullPointerException o

Review Request 23644: Patch for KAFKA-1541

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

Review Request 23645: Patch for KAFKA-1541

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

Review Request 23646: Patch for KAFKA-1541

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

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

[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

Review Request 23647: Patch for KAFKA-1526

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

[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] [Commented] (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:comment-tabpanel&focusedCommentId=14065192#comment-14065192 ] Raul Castro Fernandez commented on KAFKA-1526: -- Created reviewboard https://r

Review Request 23648: Patch for KAFKA-1524

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

[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] [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: (was: KAFKA-1524.patch) > Implement transactional producer >

[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: (was: KAFKA-1526.patch) > Producer performance tool should have a

[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

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

[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-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] [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] [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] [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] [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] [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] 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: (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_TopicMetadataResponse_.patch > return all liv

[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] [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=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:43 PM: -

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

[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

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

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

[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

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

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

[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

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

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

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

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

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

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

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

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

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

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

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

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

[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

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

  1   2   >