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

[ https://issues.apache.org/jira/browse/KAFKA-1666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14164804#comment-14164804 ] rajendram kathees edited comment on KAFKA-1666 at 10/9/14 5:58 AM: -

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

[ 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

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

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] [Resolved] (KAFKA-1666) Issue for sending more message to Kafka Broker

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

Re: Review Request 26373: Patch for KAFKA-1647

> 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

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

[ https://issues.apache.org/jira/browse/KAFKA-1681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14164710#comment-14164710 ] Jun Rao commented on KAFKA-1681: Yes, or just set deleteTopicStateChanged to true instead

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

> On Oct. 8, 2014, 2:04 a.m., Joel Koshy wrote: > > clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java, line > > 271 > > > > > > Where is this used? Used in ProducerConfig line 180: .define(ACKS_CON

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

[ https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14164557#comment-14164557 ] Jay Kreps commented on KAFKA-1646: -- Interesting. What is the behavior of RandomAccessFile

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

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

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

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

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

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

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

[ 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

[ https://issues.apache.org/jira/browse/KAFKA-1648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14164487#comment-14164487 ] Mayuresh Gharat commented on KAFKA-1648: Updated reviewboard https://reviews.apach

Re: Review Request 26291: Patch for KAFKA-1648

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

Re: Review Request 26291: Patch for KAFKA-1648

> 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: https://reviews.apache

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

[ 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:29:14.patch > Round robin consumer balance throws an NPE

Re: Review Request 26291: Patch for KAFKA-1648

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

Re: Review Request 26291: Patch for KAFKA-1648

> On Oct. 7, 2014, 9:06 p.m., Joel Koshy wrote: > > core/src/main/scala/kafka/consumer/PartitionAssignor.scala, line 76 > > > > > > Did you mean to return this? yes. I did not want to change the return type. If there a

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

[ https://issues.apache.org/jira/browse/KAFKA-1648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14164465#comment-14164465 ] Mayuresh Gharat commented on KAFKA-1648: Updated reviewboard https://reviews.apach

Re: Review Request 26373: Patch for KAFKA-1647

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

Re: Java New Producer IO Thread Name

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 wrote: > That sounds reasonable. Could you file a jira to track this? > > Thanks, > > Jun > > On Tue, Oct 7, 2014 at 7:47

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

[ https://issues.apache.org/jira/browse/KAFKA-1692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14164275#comment-14164275 ] Bhavesh Mistry commented on KAFKA-1692: --- Description is just suggestion. Sorry coul

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

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] [Comment Edited] (KAFKA-1684) Implement TLS/SSL authentication

[ https://issues.apache.org/jira/browse/KAFKA-1684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14164147#comment-14164147 ] Joe Stein edited comment on KAFKA-1684 at 10/8/14 8:59 PM: --- Thre

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

[ https://issues.apache.org/jira/browse/KAFKA-1684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14164147#comment-14164147 ] Joe Stein commented on KAFKA-1684: -- Three related ticket for this. I want to get one mor

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

[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14164017#comment-14164017 ] Joe Stein commented on KAFKA-1477: -- We need to have it support configurable ports and we

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

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

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] [Updated] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

[ 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] [Updated] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

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

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

[ 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] [Commented] (KAFKA-1681) Newly elected KafkaController might not start deletion of pending topics

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

Schema Based Topics

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 ke

[jira] [Commented] (KAFKA-1644) Inherit FetchResponse from RequestOrResponse

[ https://issues.apache.org/jira/browse/KAFKA-1644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14163449#comment-14163449 ] Anton Karamanov commented on KAFKA-1644: Thanks. Is there a chance it could be in

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

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 Fe