Jenkins build is back to normal : Kafka-trunk #199

See

[jira] [Commented] (KAFKA-1283) Log4jAppender is unable to send the message.

[ https://issues.apache.org/jira/browse/KAFKA-1283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14018491#comment-14018491 ] Neha Narkhede commented on KAFKA-1283: -- [~babakbehzad] Not really so far. We are up f

[jira] [Updated] (KAFKA-1283) Log4jAppender is unable to send the message.

[ https://issues.apache.org/jira/browse/KAFKA-1283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1283: - Labels: newbie (was: easyfix) > Log4jAppender is unable to send the message. > -

Re: Review Request 21899: Patch for KAFKA-1382

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21899/#review44799 --- This looks great overall. However, something that I missed on my las

[jira] [Resolved] (KAFKA-1438) Migrate kafka client tools

[ https://issues.apache.org/jira/browse/KAFKA-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1438. -- Resolution: Fixed Fix Version/s: (was: 0.9.0) 0.8.2 Thanks for th

[jira] [Commented] (KAFKA-1438) Migrate kafka client tools

[ https://issues.apache.org/jira/browse/KAFKA-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14018480#comment-14018480 ] Neha Narkhede commented on KAFKA-1438: -- I just reviewed the last reviewboard. Looks g

[jira] [Comment Edited] (KAFKA-1438) Migrate kafka client tools

[ https://issues.apache.org/jira/browse/KAFKA-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14018480#comment-14018480 ] Neha Narkhede edited comment on KAFKA-1438 at 6/5/14 5:06 AM: --

[jira] [Commented] (KAFKA-1438) Migrate kafka client tools

[ https://issues.apache.org/jira/browse/KAFKA-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14018464#comment-14018464 ] Neha Narkhede commented on KAFKA-1438: -- [~sriharsha] So could you point me to the pat

[jira] [Updated] (KAFKA-1443) Add delete topic to topic commands and update DeleteTopicCommand

[ https://issues.apache.org/jira/browse/KAFKA-1443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timothy Chen updated KAFKA-1443: Attachment: KAFKA-1443_2014-06-04_20:51:44.patch > Add delete topic to topic commands and update De

[jira] [Commented] (KAFKA-1443) Add delete topic to topic commands and update DeleteTopicCommand

[ https://issues.apache.org/jira/browse/KAFKA-1443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14018454#comment-14018454 ] Timothy Chen commented on KAFKA-1443: - Updated reviewboard https://reviews.apache.org/

Re: Review Request 21272: Patch for KAFKA-1443

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21272/ --- (Updated June 5, 2014, 3:51 a.m.) Review request for kafka. Bugs: KAFKA-1443

Re: camel-kafka component review

This is great. I added it to our Ecosystem page. Thanks for sharing! -Neha On Wed, Jun 4, 2014 at 11:26 AM, Ioannis Polyzos wrote: > Hi everyone, > > I would like to draw your attention to a camel-kafka component I have > recently

Re: deleting topics

Hey Tim, Thanks for the patch. I just reviewed it. -Neha On Wed, Jun 4, 2014 at 10:16 AM, Timothy Chen wrote: > On the same note, perhaps someone can review my patch for the delete > topic command? > > https://reviews.apache.org/r/21272/ > > Thanks! > > Tim > > On Wed, Jun 4, 2014 at 9:54 AM,

Re: Review Request 21272: Patch for KAFKA-1443

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21272/#review44790 --- core/src/main/scala/kafka/admin/DeleteTopicCommand.scala

Re: [DISCUSS] Kafka Security Specific Features

I like the idea of working on the spec and prioritizing. I will update the wiki. - Joestein On Wed, Jun 4, 2014 at 1:11 PM, Jay Kreps wrote: > Hey Joe, > > Thanks for kicking this discussion off! I totally agree that for something > that acts as a central message broker security is critical fe

Build failed in Jenkins: Kafka-trunk #198

See Changes: [junrao] kafka-1473; transient unit test failure in testRequestHandlingDuringDeleteTopic; patched by Guozhang Wang; reviewed by Jun Rao -- [...truncated 1553 lines...] kafka.producer.P

[jira] [Commented] (KAFKA-1283) Log4jAppender is unable to send the message.

[ https://issues.apache.org/jira/browse/KAFKA-1283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14018276#comment-14018276 ] Babak Behzad commented on KAFKA-1283: - Any progress on this? I am having the same issu

[jira] [Closed] (KAFKA-1484) Please create a DOAP file for your TLP

[ https://issues.apache.org/jira/browse/KAFKA-1484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebb closed KAFKA-1484. --- > Please create a DOAP file for your TLP > -- > > Key: KAFKA-1484 >

[jira] [Resolved] (KAFKA-1484) Please create a DOAP file for your TLP

[ https://issues.apache.org/jira/browse/KAFKA-1484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebb resolved KAFKA-1484. - Resolution: Fixed Sorry, please ignore, there was a bug in the script that checked for DOAPs > Please create a D

[jira] [Created] (KAFKA-1484) Please create a DOAP file for your TLP

Sebb created KAFKA-1484: --- Summary: Please create a DOAP file for your TLP Key: KAFKA-1484 URL: https://issues.apache.org/jira/browse/KAFKA-1484 Project: Kafka Issue Type: Task Reporter: Seb

[jira] [Resolved] (KAFKA-1473) transient unit test failure in testRequestHandlingDuringDeleteTopic

[ https://issues.apache.org/jira/browse/KAFKA-1473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1473. Resolution: Fixed Fix Version/s: 0.8.2 Assignee: Guozhang Wang Thanks for the patch. +1. Co

Re: Review Request 21899: Patch for KAFKA-1382

> On June 2, 2014, 9:01 p.m., Neha Narkhede wrote: > > core/src/main/scala/kafka/utils/ReplicationUtils.scala, line 46 > > > > > > Updating the zookeeper path if the contents are equal even if the > > version does not

[jira] [Updated] (KAFKA-1382) Update zkVersion on partition state update failures

[ https://issues.apache.org/jira/browse/KAFKA-1382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1382: -- Attachment: KAFKA-1382_2014-06-04_12:30:40.patch > Update zkVersion on partitio

[jira] [Commented] (KAFKA-1382) Update zkVersion on partition state update failures

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

Re: Review Request 21899: Patch for KAFKA-1382

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21899/ --- (Updated June 4, 2014, 7:30 p.m.) Review request for kafka. Bugs: KAFKA-1382

[jira] [Updated] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Otis Gospodnetic updated KAFKA-1481: Description: MBeans should not use dashes or underscores as separators because these chara

camel-kafka component review

Hi everyone, I would like to draw your attention to a camel-kafka component I have recently developed and kindly ask your feedback and advice on this. You can find the component at https://github.com/ipolyzos/camel-kafka and the documentation at https://github.com/ipolyzos/camel-kafka/wiki

[jira] [Commented] (KAFKA-1456) Add LZ4 and LZ4C as a compression codec

[ https://issues.apache.org/jira/browse/KAFKA-1456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14017931#comment-14017931 ] Joel Koshy commented on KAFKA-1456: --- Actually I think there is a run-time dependency. *

Re: Review Request 22063: Patch for KAFKA-1472

> On May 30, 2014, 6:25 a.m., Guozhang Wang wrote: > > clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java, > > line 130 > > > > > > When compression is not used, should we return the default value

[jira] [Updated] (KAFKA-1472) Add the compression ratio metrics in the new producer

[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1472: Attachment: KAFKA-1472_2014-06-04_10:31:44.patch > Add the compression ratio metrics in the new producer >

[jira] [Commented] (KAFKA-1472) Add the compression ratio metrics in the new producer

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

Re: Review Request 22063: Patch for KAFKA-1472

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/22063/ --- (Updated June 4, 2014, 5:31 p.m.) Review request for kafka. Bugs: KAFKA-1472

Re: deleting topics

On the same note, perhaps someone can review my patch for the delete topic command? https://reviews.apache.org/r/21272/ Thanks! Tim On Wed, Jun 4, 2014 at 9:54 AM, Guozhang Wang wrote: > The delete topic utility should be workable in the next release 0.8.2. > > Guozhang > > > On Wed, Jun 4, 20

Re: [DISCUSS] Kafka Security Specific Features

Hey Joe, Thanks for kicking this discussion off! I totally agree that for something that acts as a central message broker security is critical feature. I think a number of people have been interested in this topic and several people have put effort into special purpose security efforts. Since mos

[jira] [Updated] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1481: - Fix Version/s: (was: 0.8.1) > Stop using dashes AND underscores as separators in MBean names

[jira] [Updated] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1481: - Affects Version/s: (was: 0.8.1.1) > Stop using dashes AND underscores as separators in MBean

[jira] [Commented] (KAFKA-1475) Kafka consumer stops LeaderFinder/FetcherThreads, but application does not know

[ https://issues.apache.org/jira/browse/KAFKA-1475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14017849#comment-14017849 ] Guozhang Wang commented on KAFKA-1475: -- Hello Hang, Yes we are aware of of this issu

Re: Please subscribe

Hello, this is a self-service mailing list: http://kafka.apache.org/contact.html Guozhang On Tue, Jun 3, 2014 at 10:04 PM, Raghavendra Nandagopal < allaboutka...@gmail.com> wrote: > > -- -- Guozhang

[jira] [Commented] (KAFKA-1469) Util.abs function does not return correct absolute values for negative values

[ https://issues.apache.org/jira/browse/KAFKA-1469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14017833#comment-14017833 ] Guozhang Wang commented on KAFKA-1469: -- Thanks for the patch, I am +1 on this one. >

[jira] [Updated] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Otis Gospodnetic updated KAFKA-1481: Summary: Stop using dashes AND underscores as separators in MBean names (was: Stop using d

[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=14017720#comment-14017720 ] Jun Rao commented on KAFKA-1477: For most people, they will have to make code changes to u

Please subscribe

Re: [DISCUSS] Kafka Security Specific Features

Hey Todd, I think you are right on both points. Maybe instead of modularizing authorization we could instead support some feature like being able to associate "labels" for the application specific items (topic name, reads/writes, delete topic, change config, rate limiting, etc) and then accept a

[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=14017534#comment-14017534 ] Joe Stein commented on KAFKA-1477: -- << 1. Since this is a relatively big change on an imp