[jira] [Created] (KAFKA-1689) automatic migration of log dirs to new locations

2014-10-08 Thread Javier Alba (JIRA)
Javier Alba created KAFKA-1689: -- Summary: automatic migration of log dirs to new locations Key: KAFKA-1689 URL: https://issues.apache.org/jira/browse/KAFKA-1689 Project: Kafka Issue Type: New

Schema Based Topics

2014-10-08 Thread Joe Stein
I started to put thoughts on what a schema based topic would look like https://cwiki.apache.org/confluence/display/KAFKA/Schema+based+topics The main idea around this feature is that topics will have a registry of what schemas it support and validate for producing and return (in addition to the

[jira] [Commented] (KAFKA-1681) Newly elected KafkaController might not start deletion of pending topics

2014-10-08 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14163604#comment-14163604 ] Sriharsha Chintalapani commented on KAFKA-1681: --- [~nehanarkhede] [~junrao]

[jira] [Updated] (KAFKA-1681) Newly elected KafkaController might not start deletion of pending topics

2014-10-08 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1681: - Reviewer: Neha Narkhede Newly elected KafkaController might not start deletion of pending topics

[jira] [Updated] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

2014-10-08 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1477: - Fix Version/s: (was: 0.9.0) 0.8.3 add authentication layer and initial JKS x509

[jira] [Updated] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

2014-10-08 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1477: - Issue Type: Sub-task (was: New Feature) Parent: KAFKA-1682 add authentication layer and initial

[jira] [Created] (KAFKA-1691) new java consumer needs ssl support as a client

2014-10-08 Thread Joe Stein (JIRA)
Joe Stein created KAFKA-1691: Summary: new java consumer needs ssl support as a client Key: KAFKA-1691 URL: https://issues.apache.org/jira/browse/KAFKA-1691 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-1690) new java producer needs ssl support as a client

2014-10-08 Thread Joe Stein (JIRA)
Joe Stein created KAFKA-1690: Summary: new java producer needs ssl support as a client Key: KAFKA-1690 URL: https://issues.apache.org/jira/browse/KAFKA-1690 Project: Kafka Issue Type: Sub-task

[jira] [Commented] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

2014-10-08 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14164017#comment-14164017 ] Joe Stein commented on KAFKA-1477: -- We need to have it support configurable ports and we

[jira] [Commented] (KAFKA-1684) Implement TLS/SSL authentication

2014-10-08 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14164147#comment-14164147 ] Joe Stein commented on KAFKA-1684: -- Three related ticket for this. I want to get one

[jira] [Comment Edited] (KAFKA-1684) Implement TLS/SSL authentication

2014-10-08 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14164147#comment-14164147 ] Joe Stein edited comment on KAFKA-1684 at 10/8/14 8:59 PM: ---

[jira] [Created] (KAFKA-1692) [Java New Producer] IO Thread Name Must include Client ID

2014-10-08 Thread Bhavesh Mistry (JIRA)
Bhavesh Mistry created KAFKA-1692: - Summary: [Java New Producer] IO Thread Name Must include Client ID Key: KAFKA-1692 URL: https://issues.apache.org/jira/browse/KAFKA-1692 Project: Kafka

[jira] [Commented] (KAFKA-1692) [Java New Producer] IO Thread Name Must include Client ID

2014-10-08 Thread Bhavesh Mistry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14164275#comment-14164275 ] Bhavesh Mistry commented on KAFKA-1692: --- Description is just suggestion. Sorry

Re: Java New Producer IO Thread Name

2014-10-08 Thread Bhavesh Mistry
Hi Jun, There is ticket with suggestion. https://issues.apache.org/jira/browse/KAFKA-1692 Thanks for your support. Thanks, Bhavesh On Tue, Oct 7, 2014 at 3:29 PM, Jun Rao jun...@gmail.com wrote: That sounds reasonable. Could you file a jira to track this? Thanks, Jun On Tue, Oct 7,

Re: Review Request 26373: Patch for KAFKA-1647

2014-10-08 Thread Jiangjie Qin
On Oct. 7, 2014, 12:15 a.m., Guozhang Wang wrote: Since now the first iteration of if statements is only used for logging, could we just merge it into the second check? Guozhang, thanks for the review. I actually thought about it before. I agree that the code looks simpler if we just

[jira] [Commented] (KAFKA-1648) Round robin consumer balance throws an NPE when there are no topics

2014-10-08 Thread Mayuresh Gharat (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14164465#comment-14164465 ] Mayuresh Gharat commented on KAFKA-1648: Updated reviewboard

Re: Review Request 26291: Patch for KAFKA-1648

2014-10-08 Thread Mayuresh Gharat
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26291/ --- (Updated Oct. 9, 2014, 12:29 a.m.) Review request for kafka. Bugs:

Re: Review Request 26291: Patch for KAFKA-1648

2014-10-08 Thread Mayuresh Gharat
On Oct. 4, 2014, 11:33 p.m., Neha Narkhede wrote: Can you try to add a unit test for this? Yes I will try and add unit test for this - Mayuresh --- This is an automatically generated e-mail. To reply, visit:

Re: Review Request 26291: Patch for KAFKA-1648

2014-10-08 Thread Mayuresh Gharat
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26291/ --- (Updated Oct. 9, 2014, 12:46 a.m.) Review request for kafka. Bugs:

[jira] [Updated] (KAFKA-1648) Round robin consumer balance throws an NPE when there are no topics

2014-10-08 Thread Mayuresh Gharat (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat updated KAFKA-1648: --- Attachment: KAFKA-1648_2014-10-08_17:46:45.patch Round robin consumer balance throws an NPE

[jira] [Commented] (KAFKA-1648) Round robin consumer balance throws an NPE when there are no topics

2014-10-08 Thread Mayuresh Gharat (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14164487#comment-14164487 ] Mayuresh Gharat commented on KAFKA-1648: Updated reviewboard

Review Request 26474: KAFKA-1654 Provide a way to override server configuration from command line

2014-10-08 Thread Jarek Cecho
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26474/ --- Review request for kafka. Bugs: SQOOP-1654

[jira] [Updated] (KAFKA-1654) Provide a way to override server configuration from command line

2014-10-08 Thread Jarek Jarcec Cecho (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jarek Jarcec Cecho updated KAFKA-1654: -- Fix Version/s: 0.8.3 Affects Version/s: 0.8.1.1 Status: Patch

[jira] [Updated] (KAFKA-1654) Provide a way to override server configuration from command line

2014-10-08 Thread Jarek Jarcec Cecho (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jarek Jarcec Cecho updated KAFKA-1654: -- Attachment: KAFKA-1654.patch Finally attaching the patch. My apologies for the delay

[jira] [Commented] (KAFKA-1646) Improve consumer read performance for Windows

2014-10-08 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14164557#comment-14164557 ] Jay Kreps commented on KAFKA-1646: -- Interesting. What is the behavior of

Re: Review Request 25886: KAFKA-1555: provide strong consistency with reasonable availability

2014-10-08 Thread Gwen Shapira
On Oct. 8, 2014, 2:04 a.m., Joel Koshy wrote: clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java, line 271 https://reviews.apache.org/r/25886/diff/8/?file=714236#file714236line271 Where is this used? Used in ProducerConfig line 180: .define(ACKS_CONFIG,

[jira] [Commented] (KAFKA-1681) Newly elected KafkaController might not start deletion of pending topics

2014-10-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14164710#comment-14164710 ] Jun Rao commented on KAFKA-1681: Yes, or just set deleteTopicStateChanged to true instead

Re: Review Request 26373: Patch for KAFKA-1647

2014-10-08 Thread Guozhang Wang
On Oct. 7, 2014, 12:15 a.m., Guozhang Wang wrote: Since now the first iteration of if statements is only used for logging, could we just merge it into the second check? Jiangjie Qin wrote: Guozhang, thanks for the review. I actually thought about it before. I agree that the code

[jira] [Resolved] (KAFKA-1666) Issue for sending more message to Kafka Broker

2014-10-08 Thread rajendram kathees (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] rajendram kathees resolved KAFKA-1666. -- Resolution: Won't Fix Issue for sending more message to Kafka Broker

[jira] [Created] (KAFKA-1693) Issue sending more messages to single Kafka server (Load testing for Kafka transport)

2014-10-08 Thread rajendram kathees (JIRA)
rajendram kathees created KAFKA-1693: Summary: Issue sending more messages to single Kafka server (Load testing for Kafka transport) Key: KAFKA-1693 URL: https://issues.apache.org/jira/browse/KAFKA-1693

[jira] [Closed] (KAFKA-1666) Issue for sending more message to Kafka Broker

2014-10-08 Thread rajendram kathees (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] rajendram kathees closed KAFKA-1666. Issue is that producer connection was not closed properly. Issue for sending more message to