[jira] [Commented] (KAFKA-2466) ConsoleConsumer throws ConcurrentModificationException on termination

[ https://issues.apache.org/jira/browse/KAFKA-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14710732#comment-14710732 ] Ewen Cheslack-Postava commented on KAFKA-2466: -- This isn't a behavior regress

[jira] [Created] (KAFKA-2468) SIGINT during Kafka server startup can leave server deadlocked

Ashish K Singh created KAFKA-2468: - Summary: SIGINT during Kafka server startup can leave server deadlocked Key: KAFKA-2468 URL: https://issues.apache.org/jira/browse/KAFKA-2468 Project: Kafka

[GitHub] kafka pull request: KAFKA-2468: SIGINT during Kafka server startup...

GitHub user SinghAsDev opened a pull request: https://github.com/apache/kafka/pull/167 KAFKA-2468: SIGINT during Kafka server startup can leave server deadlocked As we handle exceptions or invalid states in Kafka server by shutting it down, there is no reason to use exit() and not h

[jira] [Created] (KAFKA-2469) System test console consumer logs should write all messages to debug logger

Ewen Cheslack-Postava created KAFKA-2469: Summary: System test console consumer logs should write all messages to debug logger Key: KAFKA-2469 URL: https://issues.apache.org/jira/browse/KAFKA-2469

[jira] [Commented] (KAFKA-2468) SIGINT during Kafka server startup can leave server deadlocked

[ https://issues.apache.org/jira/browse/KAFKA-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14710800#comment-14710800 ] ASF GitHub Bot commented on KAFKA-2468: --- GitHub user SinghAsDev opened a pull reques

[jira] [Commented] (KAFKA-2466) ConsoleConsumer throws ConcurrentModificationException on termination

[ https://issues.apache.org/jira/browse/KAFKA-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14710804#comment-14710804 ] Ashish K Singh commented on KAFKA-2466: --- OK, thanks for taking care of it. > Consol

[jira] [Commented] (KAFKA-2467) ConsoleConsumer regressions

[ https://issues.apache.org/jira/browse/KAFKA-2467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14710825#comment-14710825 ] Ismael Juma commented on KAFKA-2467: [~ewencp], do I understand correctly that the sys

[jira] [Commented] (KAFKA-2467) ConsoleConsumer regressions

[ https://issues.apache.org/jira/browse/KAFKA-2467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14710829#comment-14710829 ] Ewen Cheslack-Postava commented on KAFKA-2467: -- [~ijuma] Sort of. We still ne

[jira] [Commented] (KAFKA-2467) ConsoleConsumer regressions

[ https://issues.apache.org/jira/browse/KAFKA-2467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14710836#comment-14710836 ] Ismael Juma commented on KAFKA-2467: Thanks for the explanation [~ewencp]. That sounds

[jira] [Commented] (KAFKA-2467) ConsoleConsumer regressions

[ https://issues.apache.org/jira/browse/KAFKA-2467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14710860#comment-14710860 ] Ben Stopford commented on KAFKA-2467: - Apologies for this regression. 2015 was adapted

[jira] [Commented] (KAFKA-2467) ConsoleConsumer regressions

[ https://issues.apache.org/jira/browse/KAFKA-2467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14710873#comment-14710873 ] Ewen Cheslack-Postava commented on KAFKA-2467: -- No worries, I was just thankf

[GitHub] kafka pull request: KAFKA-1369 - snappy version update 1.1.x

Github user thinker0 closed the pull request at: https://github.com/apache/kafka/pull/31 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (KAFKA-1369) snappy version update 1.1.x

[ https://issues.apache.org/jira/browse/KAFKA-1369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14710907#comment-14710907 ] ASF GitHub Bot commented on KAFKA-1369: --- Github user thinker0 closed the pull reques

[jira] [Commented] (KAFKA-2385) zookeeper-shell does not work

[ https://issues.apache.org/jira/browse/KAFKA-2385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711084#comment-14711084 ] João Reis commented on KAFKA-2385: -- Hi guys, Maybe is not related with this issue, but

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711100#comment-14711100 ] Navjot commented on KAFKA-1690: --- @Sriharsha Please find the java version below: {{java versi

[jira] [Comment Edited] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711100#comment-14711100 ] Navjot edited comment on KAFKA-1690 at 8/25/15 11:32 AM: - [~harsha

kafka producer-perf-test.sh compression-codec not working

Hi, I have bene trying to use kafka-producer-perf-test.sh to arrive at certain benchmarks. When I try to run it with --compression-codec values of 1, 2 and 3, I notice increased throughput compared to NoCompressionCodec But, When I checked the Producerperformance.scala, I saw that the the `produc

[jira] [Created] (KAFKA-2470) kafka-producer-perf-test.sh can't configure all to request-num-acks

Bo Wang created KAFKA-2470: -- Summary: kafka-producer-perf-test.sh can't configure all to request-num-acks Key: KAFKA-2470 URL: https://issues.apache.org/jira/browse/KAFKA-2470 Project: Kafka Issue

Re: kafka producer-perf-test.sh compression-codec not working

Hi Erik, I have put my efforts on the produce side till now, Thanks for making me aware that consumer will decompress automatically. I'll also consider your point on creating real-life messages But, I have still have one confusion - Why would the current ProducerPerformance.scala compress an Ar

[jira] [Created] (KAFKA-2471) Replicas Order and Leader out of sync

Manish Sharma created KAFKA-2471: Summary: Replicas Order and Leader out of sync Key: KAFKA-2471 URL: https://issues.apache.org/jira/browse/KAFKA-2471 Project: Kafka Issue Type: Bug Affec

Re: kafka producer-perf-test.sh compression-codec not working

Hi Prabhjot, There are two important things to know about kafka compression: First uncompression happens automatically in the consumer (https://cwiki.apache.org/confluence/display/KAFKA/Compression) so you should see ascii returned on the consumer side. The best way to see if compression has happe

[jira] [Comment Edited] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711100#comment-14711100 ] Navjot edited comment on KAFKA-1690 at 8/25/15 2:15 PM: [~harsha_c

Re: kafka producer-perf-test.sh compression-codec not working

Prabhjot, When no compression is being used, it should have only a tiny impact on performance. But when it is enabled it will make it as though the message payload is small and nearly constant, regardless as to how large the configured message size is. I think that the answer is that this is r

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711376#comment-14711376 ] Rajasekar Elango commented on KAFKA-1690: - SSLv3 was disabled since jdk version JD

Re: kafka producer-perf-test.sh compression-codec not working

Hi Erik, Thanks for your inputs. How can we measure round trip latency using kafka-producer-perf-test.sh ? or any other tool ? Regards, Prabhjot On Tue, Aug 25, 2015 at 7:41 PM, Helleren, Erik wrote: > Prabhjot, > When no compression is being used, it should have only a tiny impact on > perf

[jira] [Created] (KAFKA-2472) Fix kafka ssl configs to not throw warnings

Sriharsha Chintalapani created KAFKA-2472: - Summary: Fix kafka ssl configs to not throw warnings Key: KAFKA-2472 URL: https://issues.apache.org/jira/browse/KAFKA-2472 Project: Kafka I

[jira] [Updated] (KAFKA-1811) Ensuring registered broker host:port is unique

[ https://issues.apache.org/jira/browse/KAFKA-1811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edward Ribeiro updated KAFKA-1811: -- Summary: Ensuring registered broker host:port is unique (was: ensuring registered broker host:p

[jira] [Commented] (KAFKA-2385) zookeeper-shell does not work

[ https://issues.apache.org/jira/browse/KAFKA-2385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711441#comment-14711441 ] João Reis commented on KAFKA-2385: -- It seems to be a Zookeeper problem as stated here: h

[jira] [Commented] (KAFKA-2472) Fix kafka ssl configs to not throw warnings

[ https://issues.apache.org/jira/browse/KAFKA-2472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711500#comment-14711500 ] Gwen Shapira commented on KAFKA-2472: - I'm wondering if we still need the unknown conf

[jira] [Commented] (KAFKA-2472) Fix kafka ssl configs to not throw warnings

[ https://issues.apache.org/jira/browse/KAFKA-2472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711506#comment-14711506 ] Sriharsha Chintalapani commented on KAFKA-2472: --- [~gwenshap] I think we sho

[GitHub] kafka pull request: KAFKA-1811 Ensuring registered broker host:por...

GitHub user eribeiro opened a pull request: https://github.com/apache/kafka/pull/168 KAFKA-1811 Ensuring registered broker host:port is unique Adds a ZKLock recipe implementation to guarantee that the host:port pair is unique among the brokers registered on ZooKeeper. You can merge

[jira] [Commented] (KAFKA-1811) Ensuring registered broker host:port is unique

[ https://issues.apache.org/jira/browse/KAFKA-1811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711498#comment-14711498 ] ASF GitHub Bot commented on KAFKA-1811: --- GitHub user eribeiro opened a pull request:

[jira] [Updated] (KAFKA-2122) Remove controller.message.queue.size Config

[ https://issues.apache.org/jira/browse/KAFKA-2122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2122: Fix Version/s: 0.8.3 > Remove controller.message.queue.size Config > ---

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711565#comment-14711565 ] Sriharsha Chintalapani commented on KAFKA-1690: --- [~NavjotBhardwaj] it doesn'

Re: KAFKA-2364 migrate docs from SVN to git

I thought Gwen's suggestion was to us a separate folder in the same repo for docs instead of a separate branch, Gwen can correct me if I was wrong? Guozhang On Mon, Aug 24, 2015 at 10:31 AM, Manikumar Reddy wrote: > Hi, > >Infra team created git repo for kafka site docs. > >Gwen/Guozhan

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711624#comment-14711624 ] Sourabh Chandak commented on KAFKA-1690: [~sriharsha] Is the simple consumer also

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711679#comment-14711679 ] Sriharsha Chintalapani commented on KAFKA-1690: --- [~sourabh0612] SSL or any s

Re: Review Request 33378: Patch for KAFKA-2136

> On Aug. 22, 2015, 12:45 a.m., Joel Koshy wrote: > > clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java, > > line 107 > > > > > > This will probably need a versionId as well (as is done i

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711698#comment-14711698 ] Sourabh Chandak commented on KAFKA-1690: [~sriharsha] Sorry it might be a noob que

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711715#comment-14711715 ] Navjot commented on KAFKA-1690: --- Yes [~harsha_ch] I deployed it on windows without SSL and i

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711718#comment-14711718 ] Navjot commented on KAFKA-1690: --- Yes [~harsha_ch] I deployed it on windows without SSL and i

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711717#comment-14711717 ] Navjot commented on KAFKA-1690: --- Yes [~harsha_ch] I deployed it on windows without SSL and i

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711719#comment-14711719 ] Navjot commented on KAFKA-1690: --- Yes [~harsha_ch] I deployed it on windows without SSL and i

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711720#comment-14711720 ] Navjot commented on KAFKA-1690: --- Yes [~harsha_ch] I deployed it on windows without SSL and i

[jira] [Issue Comment Deleted] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navjot updated KAFKA-1690: -- Comment: was deleted (was: Yes [~harsha_ch] I deployed it on windows without SSL and it was running absolutely

[jira] [Issue Comment Deleted] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navjot updated KAFKA-1690: -- Comment: was deleted (was: Yes [~harsha_ch] I deployed it on windows without SSL and it was running absolutely

[jira] [Issue Comment Deleted] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navjot updated KAFKA-1690: -- Comment: was deleted (was: Yes [~harsha_ch] I deployed it on windows without SSL and it was running absolutely

[jira] [Issue Comment Deleted] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navjot updated KAFKA-1690: -- Comment: was deleted (was: Yes [~harsha_ch] I deployed it on windows without SSL and it was running absolutely

[jira] [Issue Comment Deleted] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navjot updated KAFKA-1690: -- Comment: was deleted (was: Yes [~harsha_ch] I deployed it on windows without SSL and it was running absolutely

Re: kafka producer-perf-test.sh compression-codec not working

Prabhjot, You can’t do it with producer perf test, but its relatively simple to implement. The message body includes a timestamp of when your producer produces, and the consumer looks at the difference between between the timestamp in the body and the current timestamp. Or, if you were looking

Re: kafka producer-perf-test.sh compression-codec not working

Hi Erik, Thanks for these inputs I'll implement it Regards, Prabhjot On Aug 25, 2015 11:53 PM, "Helleren, Erik" wrote: > Prabhjot, > You can’t do it with producer perf test, but its relatively simple to > implement. The message body includes a timestamp of when your producer > produces, and the

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711733#comment-14711733 ] Ismael Juma commented on KAFKA-1690: [~sourabh0612], it would be better to take this t

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711741#comment-14711741 ] Navjot commented on KAFKA-1690: --- Yes [~harsha_ch] I deployed it on windows and producers/con

[jira] [Commented] (KAFKA-2136) Client side protocol changes to return quota delays

[ https://issues.apache.org/jira/browse/KAFKA-2136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711745#comment-14711745 ] Aditya A Auradkar commented on KAFKA-2136: -- Updated reviewboard https://reviews.a

Re: Review Request 33378: Patch for KAFKA-2136

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33378/ --- (Updated Aug. 25, 2015, 6:30 p.m.) Review request for kafka, Joel Koshy and Jun

Re: Review Request 33378: Patch for KAFKA-2136

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33378/ --- (Updated Aug. 25, 2015, 6:30 p.m.) Review request for kafka, Joel Koshy and Jun

[jira] [Updated] (KAFKA-2136) Client side protocol changes to return quota delays

[ https://issues.apache.org/jira/browse/KAFKA-2136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya A Auradkar updated KAFKA-2136: - Attachment: KAFKA-2136_2015-08-25_11:29:52.patch > Client side protocol changes to return

Can I get permission to create proposal

For pinning the controller to a broker KAFKA-1778 I want to create a proposal detailing the design. My user id is:anigam -Abhishek

[jira] [Updated] (KAFKA-2367) Add Copycat runtime data API

[ https://issues.apache.org/jira/browse/KAFKA-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2367: Status: Patch Available (was: Open) > Add Copycat runtime data API > >

[jira] [Commented] (KAFKA-1387) Kafka getting stuck creating ephemeral node it has already created when two zookeeper sessions are established in a very short period of time

[ https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711838#comment-14711838 ] Guozhang Wang commented on KAFKA-1387: -- Thanks [~fpj], thanks for the patch. Here are

[jira] [Created] (KAFKA-2473) Not able to release version with patch jira-1591

Amar created KAFKA-2473: --- Summary: Not able to release version with patch jira-1591 Key: KAFKA-2473 URL: https://issues.apache.org/jira/browse/KAFKA-2473 Project: Kafka Issue Type: Bug Compon

[jira] [Updated] (KAFKA-2473) Not able to find release version with patch jira-1591

[ https://issues.apache.org/jira/browse/KAFKA-2473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amar updated KAFKA-2473: Summary: Not able to find release version with patch jira-1591 (was: Not able to release version with patch jira-15

[jira] [Updated] (KAFKA-2461) request logger no longer logs extra information in debug mode

[ https://issues.apache.org/jira/browse/KAFKA-2461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2461: Fix Version/s: 0.8.3 > request logger no longer logs extra information in debug mode > -

[jira] [Commented] (KAFKA-2461) request logger no longer logs extra information in debug mode

[ https://issues.apache.org/jira/browse/KAFKA-2461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711994#comment-14711994 ] Gwen Shapira commented on KAFKA-2461: - We'll need it in 0.8.3, since we are losing dia

[jira] [Commented] (KAFKA-2473) Not able to find release version with patch jira-1591

[ https://issues.apache.org/jira/browse/KAFKA-2473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14712009#comment-14712009 ] Edward Ribeiro commented on KAFKA-2473: --- Hi Amar, please, post this kind of question

[jira] [Comment Edited] (KAFKA-2473) Not able to find release version with patch jira-1591

[ https://issues.apache.org/jira/browse/KAFKA-2473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14712009#comment-14712009 ] Edward Ribeiro edited comment on KAFKA-2473 at 8/25/15 9:30 PM:

[jira] [Comment Edited] (KAFKA-2473) Not able to find release version with patch jira-1591

[ https://issues.apache.org/jira/browse/KAFKA-2473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14712009#comment-14712009 ] Edward Ribeiro edited comment on KAFKA-2473 at 8/25/15 9:33 PM:

[GitHub] kafka pull request: KAFKA-2461: request logger no longer logs extr...

GitHub user SinghAsDev opened a pull request: https://github.com/apache/kafka/pull/169 KAFKA-2461: request logger no longer logs extra information in debug mode You can merge this pull request into a Git repository by running: $ git pull https://github.com/SinghAsDev/kafka KAF

[jira] [Commented] (KAFKA-2461) request logger no longer logs extra information in debug mode

[ https://issues.apache.org/jira/browse/KAFKA-2461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14712096#comment-14712096 ] ASF GitHub Bot commented on KAFKA-2461: --- GitHub user SinghAsDev opened a pull reques

[jira] [Resolved] (KAFKA-2473) Not able to find release version with patch jira-1591

[ https://issues.apache.org/jira/browse/KAFKA-2473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amar resolved KAFKA-2473. - Resolution: Not A Problem > Not able to find release version with patch jira-1591 > --

[jira] [Commented] (KAFKA-2468) SIGINT during Kafka server startup can leave server deadlocked

[ https://issues.apache.org/jira/browse/KAFKA-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14712201#comment-14712201 ] Ewen Cheslack-Postava commented on KAFKA-2468: -- Does this actually solve the

[jira] [Comment Edited] (KAFKA-2468) SIGINT during Kafka server startup can leave server deadlocked

[ https://issues.apache.org/jira/browse/KAFKA-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14712225#comment-14712225 ] Ashish K Singh edited comment on KAFKA-2468 at 8/26/15 12:13 AM: ---

[jira] [Commented] (KAFKA-2468) SIGINT during Kafka server startup can leave server deadlocked

[ https://issues.apache.org/jira/browse/KAFKA-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14712225#comment-14712225 ] Ashish K Singh commented on KAFKA-2468: --- [~ewencp] unlike exit(), halt() forcibly te

[jira] [Commented] (KAFKA-2388) subscribe(topic)/unsubscribe(topic) should either take a callback to allow user to handle exceptions or it should be synchronous.

[ https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14712236#comment-14712236 ] Jason Gustafson commented on KAFKA-2388: [~onurkaraman] I've updated the patch to

Re: Review Request 36652: Patch for KAFKA-2351

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/36652/#review96463 --- Ship it! Ship It! - Joel Koshy On Aug. 24, 2015, 10:50 p.m., May

[jira] [Updated] (KAFKA-2351) Brokers are having a problem shutting down correctly

[ https://issues.apache.org/jira/browse/KAFKA-2351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy updated KAFKA-2351: -- Resolution: Fixed Status: Resolved (was: Patch Available) Committed to trunk. > Brokers are ha

[jira] [Updated] (KAFKA-2210) KafkaAuthorizer: Add all public entities, config changes and changes to KafkaAPI and kafkaServer to allow pluggable authorizer implementation.

[ https://issues.apache.org/jira/browse/KAFKA-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Parth Brahmbhatt updated KAFKA-2210: Attachment: KAFKA-2210_2015-08-25_17:59:22.patch > KafkaAuthorizer: Add all public entities,

[jira] [Commented] (KAFKA-2210) KafkaAuthorizer: Add all public entities, config changes and changes to KafkaAPI and kafkaServer to allow pluggable authorizer implementation.

[ https://issues.apache.org/jira/browse/KAFKA-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14712282#comment-14712282 ] Parth Brahmbhatt commented on KAFKA-2210: - Updated reviewboard https://reviews.apa

Re: Review Request 34492: Patch for KAFKA-2210

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34492/ --- (Updated Aug. 26, 2015, 12:59 a.m.) Review request for kafka. Bugs: KAFKA-221

Re: Review Request 34492: Patch for KAFKA-2210

> On Aug. 23, 2015, 9:29 p.m., Jun Rao wrote: > > core/src/main/scala/kafka/security/auth/KafkaPrincipal.scala, line 21 > > > > > > There is a java version of KafkaPrincipal. Could we consolidate? consolidated. Conv

Re: Review Request 33378: Patch for KAFKA-2136

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33378/#review96470 --- Ship it! Ship It! - Joel Koshy On Aug. 25, 2015, 6:30 p.m., Adit

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

See

[jira] [Commented] (KAFKA-2145) An option to add topic owners.

[ https://issues.apache.org/jira/browse/KAFKA-2145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14712319#comment-14712319 ] Parth Brahmbhatt commented on KAFKA-2145: - [~junrao] Pinging again for review. >

[jira] [Commented] (KAFKA-2136) Client side protocol changes to return quota delays

[ https://issues.apache.org/jira/browse/KAFKA-2136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14712324#comment-14712324 ] Joel Koshy commented on KAFKA-2136: --- Thanks for the patches - pushed to trunk. Can you u

[jira] [Commented] (KAFKA-2388) subscribe(topic)/unsubscribe(topic) should either take a callback to allow user to handle exceptions or it should be synchronous.

[ https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14712347#comment-14712347 ] Onur Karaman commented on KAFKA-2388: - Sounds okay to me. I'll try to take a look at t

Re: Review Request 33378: Patch for KAFKA-2136

> On Aug. 21, 2015, 12:13 a.m., Joel Koshy wrote: > > core/src/main/scala/kafka/api/FetchResponse.scala, line 175 > > > > > > Since (in the event of multiple calls) this grouping would be repeated, > > should we ju

[jira] [Created] (KAFKA-2474) Add caching for converted Copycat schemas in JSONConverter

Ewen Cheslack-Postava created KAFKA-2474: Summary: Add caching for converted Copycat schemas in JSONConverter Key: KAFKA-2474 URL: https://issues.apache.org/jira/browse/KAFKA-2474 Project: Kafk

[jira] [Created] (KAFKA-2475) Reduce copycat configs to only specify a converter or serializer, not both

Ewen Cheslack-Postava created KAFKA-2475: Summary: Reduce copycat configs to only specify a converter or serializer, not both Key: KAFKA-2475 URL: https://issues.apache.org/jira/browse/KAFKA-2475

[jira] [Created] (KAFKA-2476) Define logical types for Copycat data API

Ewen Cheslack-Postava created KAFKA-2476: Summary: Define logical types for Copycat data API Key: KAFKA-2476 URL: https://issues.apache.org/jira/browse/KAFKA-2476 Project: Kafka Issue

[jira] [Commented] (KAFKA-2468) SIGINT during Kafka server startup can leave server deadlocked

[ https://issues.apache.org/jira/browse/KAFKA-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14712397#comment-14712397 ] Ewen Cheslack-Postava commented on KAFKA-2468: -- [~ashi.khur...@gmail.com] Ok,

[jira] [Commented] (KAFKA-2367) Add Copycat runtime data API

[ https://issues.apache.org/jira/browse/KAFKA-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14712401#comment-14712401 ] Gwen Shapira commented on KAFKA-2367: - My opinions / comments on the above: * Logical

[jira] [Commented] (KAFKA-2468) SIGINT during Kafka server startup can leave server deadlocked

[ https://issues.apache.org/jira/browse/KAFKA-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14712413#comment-14712413 ] Ashish K Singh commented on KAFKA-2468: --- [~guozhang] could you review and help with

Re: Issue when enabling SSL on broker

Hi Xiang,          Did you try following the instructions here  https://cwiki.apache.org/confluence/display/KAFKA/Deploying+SSL+for+Kafka . Whats the output of openssl s_client and which version of java and OS are you using. Thanks, Harsha On August 25, 2015 at 8:42:18 PM, Xiang Zhou (Samuel) (

[jira] [Commented] (KAFKA-2367) Add Copycat runtime data API

[ https://issues.apache.org/jira/browse/KAFKA-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14712472#comment-14712472 ] Jay Kreps commented on KAFKA-2367: -- On unions: they were kind of a disaster at LinkedIn.

Re: Issue when enabling SSL on broker

Hi,       Turns out to be a bug in the instructions in the wiki . I fixed it can you please retry generating the truststore and keystore https://cwiki.apache.org/confluence/display/KAFKA/Deploying+SSL+for+Kafka . checkout this section "All of the above steps in a bash script” to generate the keys