is SSL support feature ready to use in kafka-truck branch

2015-08-20 Thread Qi Xu
Hi folks, I tried to clone the latest version of kafka truck and try to enable the SSL. The server.properties seems not having any security related settings, and it seems there's no other config file relevant to SSL either. So may I know is this feature ready to use now in truck branch? BTW, we're

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

2015-08-20 Thread Alexander Pakulov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Pakulov reassigned KAFKA-1543: Assignee: Alexander Pakulov > Changing replication factor > ---

[jira] [Commented] (KAFKA-1683) Implement a "session" concept in the socket server

2015-08-20 Thread Parth Brahmbhatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706135#comment-14706135 ] Parth Brahmbhatt commented on KAFKA-1683: - [~gwenshap] I agree, the original KIP a

[jira] [Commented] (KAFKA-1566) Kafka environment configuration (kafka-env.sh)

2015-08-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706128#comment-14706128 ] ASF GitHub Bot commented on KAFKA-1566: --- GitHub user harshach opened a pull request:

[GitHub] kafka pull request: KAFKA-1566: Kafka environment configuration (k...

2015-08-20 Thread harshach
GitHub user harshach opened a pull request: https://github.com/apache/kafka/pull/156 KAFKA-1566: Kafka environment configuration (kafka-env.sh) You can merge this pull request into a Git repository by running: $ git pull https://github.com/harshach/kafka KAFKA-1566 Alternativ

[jira] [Updated] (KAFKA-2007) update offsetrequest for more useful information we have on broker about partition

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2007: Fix Version/s: (was: 0.8.3) > update offsetrequest for more useful information we have on broker

[jira] [Updated] (KAFKA-1912) Create a simple request re-routing facility

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1912: Fix Version/s: (was: 0.8.3) > Create a simple request re-routing facility >

[jira] [Resolved] (KAFKA-1913) App hungs when calls producer.send to wrong IP of Kafka broker

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-1913. - Resolution: Duplicate > App hungs when calls producer.send to wrong IP of Kafka broker > -

[jira] [Commented] (KAFKA-1898) compatibility testing framework

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706121#comment-14706121 ] Gwen Shapira commented on KAFKA-1898: - Looping back here [~granders], is this somethin

[jira] [Updated] (KAFKA-1911) Log deletion on stopping replicas should be async

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1911: Fix Version/s: (was: 0.8.3) > Log deletion on stopping replicas should be async > --

[jira] [Updated] (KAFKA-1897) Enhance MockProducer for more sophisticated tests

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1897: Fix Version/s: (was: 0.8.3) > Enhance MockProducer for more sophisticated tests > --

[jira] [Resolved] (KAFKA-1855) Topic unusable after unsuccessful UpdateMetadataRequest

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-1855. - Resolution: Cannot Reproduce > Topic unusable after unsuccessful UpdateMetadataRequest > -

[jira] [Updated] (KAFKA-1877) Expose version via JMX for 'new' producer

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1877: Fix Version/s: (was: 0.8.3) > Expose version via JMX for 'new' producer > -

[jira] [Updated] (KAFKA-1802) Add a new type of request for the discovery of the controller

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1802: Fix Version/s: (was: 0.8.3) > Add a new type of request for the discovery of the controller > --

[jira] [Updated] (KAFKA-1817) AdminUtils.createTopic vs kafka-topics.sh --create with partitions

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1817: Fix Version/s: (was: 0.8.3) > AdminUtils.createTopic vs kafka-topics.sh --create with partitions

[jira] [Updated] (KAFKA-1796) Sanity check partition command line tools

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1796: Fix Version/s: (was: 0.8.3) > Sanity check partition command line tools > --

[jira] [Updated] (KAFKA-1792) change behavior of --generate to produce assignment config with fair replica distribution and minimal number of reassignments

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1792: Fix Version/s: (was: 0.8.3) > change behavior of --generate to produce assignment config with fa

[jira] [Updated] (KAFKA-1842) New producer/consumer should support configurable connection timeouts

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1842: Fix Version/s: (was: 0.8.3) > New producer/consumer should support configurable connection timeo

[jira] [Updated] (KAFKA-1777) Re-factor reasign-partitions into CLI

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1777: Fix Version/s: (was: 0.8.3) > Re-factor reasign-partitions into CLI > --

[jira] [Updated] (KAFKA-1778) Create new re-elect controller admin function

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1778: Fix Version/s: (was: 0.8.3) > Create new re-elect controller admin function > --

[jira] [Updated] (KAFKA-1772) Add an Admin message type for request response

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1772: Fix Version/s: (was: 0.8.3) > Add an Admin message type for request response > -

[jira] [Updated] (KAFKA-1775) Re-factor TopicCommand into thew handerAdminMessage call

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1775: Fix Version/s: (was: 0.8.3) > Re-factor TopicCommand into thew handerAdminMessage call > --

[jira] [Updated] (KAFKA-1786) implement a global configuration feature for brokers

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1786: Fix Version/s: (was: 0.8.3) > implement a global configuration feature for brokers > ---

[jira] [Updated] (KAFKA-1774) REPL and Shell Client for Admin Message RQ/RP

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1774: Fix Version/s: (was: 0.8.3) > REPL and Shell Client for Admin Message RQ/RP > --

[jira] [Updated] (KAFKA-1566) Kafka environment configuration (kafka-env.sh)

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1566: Reviewer: Gwen Shapira > Kafka environment configuration (kafka-env.sh) > --

[jira] [Updated] (KAFKA-1893) Allow regex subscriptions in the new consumer

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1893: Reviewer: Gwen Shapira > Allow regex subscriptions in the new consumer > ---

[jira] [Commented] (KAFKA-1683) Implement a "session" concept in the socket server

2015-08-20 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706103#comment-14706103 ] Sriharsha Chintalapani commented on KAFKA-1683: --- [~gwenshap] got your point

[jira] [Commented] (KAFKA-1683) Implement a "session" concept in the socket server

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706099#comment-14706099 ] Gwen Shapira commented on KAFKA-1683: - [~harsha_ch] mmm... I'm talking about returning

[jira] [Created] (KAFKA-2456) Disable SSLv3 for ssl.enabledprotocols config on client & broker side

2015-08-20 Thread Sriharsha Chintalapani (JIRA)
Sriharsha Chintalapani created KAFKA-2456: - Summary: Disable SSLv3 for ssl.enabledprotocols config on client & broker side Key: KAFKA-2456 URL: https://issues.apache.org/jira/browse/KAFKA-2456

[jira] [Commented] (KAFKA-1683) Implement a "session" concept in the socket server

2015-08-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706097#comment-14706097 ] ASF GitHub Bot commented on KAFKA-1683: --- GitHub user gwenshap opened a pull request:

[GitHub] kafka pull request: KAFKA-1683: persisting session information in ...

2015-08-20 Thread gwenshap
GitHub user gwenshap opened a pull request: https://github.com/apache/kafka/pull/155 KAFKA-1683: persisting session information in Requests You can merge this pull request into a Git repository by running: $ git pull https://github.com/gwenshap/kafka KAFKA-1683 Alternatively

[jira] [Commented] (KAFKA-1683) Implement a "session" concept in the socket server

2015-08-20 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706096#comment-14706096 ] Sriharsha Chintalapani commented on KAFKA-1683: --- [~gwenshap] Hmm if the hand

[jira] [Commented] (KAFKA-1683) Implement a "session" concept in the socket server

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706078#comment-14706078 ] Gwen Shapira commented on KAFKA-1683: - [~parth.brahmbhatt] and [~harsha_ch]: Looking

[jira] [Commented] (KAFKA-2454) Dead lock between delete log segment and shutting down.

2015-08-20 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706021#comment-14706021 ] Jiangjie Qin commented on KAFKA-2454: - [~jjkoshy] Here are the two threads: Thread 1:

[jira] [Created] (KAFKA-2455) Test Failure: kafka.consumer.MetricsTest > testMetricsLeak

2015-08-20 Thread Gwen Shapira (JIRA)
Gwen Shapira created KAFKA-2455: --- Summary: Test Failure: kafka.consumer.MetricsTest > testMetricsLeak Key: KAFKA-2455 URL: https://issues.apache.org/jira/browse/KAFKA-2455 Project: Kafka Issu

[jira] [Commented] (KAFKA-2454) Dead lock between delete log segment and shutting down.

2015-08-20 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706019#comment-14706019 ] Joel Koshy commented on KAFKA-2454: --- I'm a bit unclear on the root cause that you descri

Re: Review Request 33378: Patch for KAFKA-2136

2015-08-20 Thread Joel Koshy
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33378/#review96009 --- core/src/main/scala/kafka/api/FetchResponse.scala (line 172)

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

2015-08-20 Thread Michael Poindexter (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705947#comment-14705947 ] Michael Poindexter commented on KAFKA-1194: --- I have created a PR that should add

[jira] [Commented] (KAFKA-2170) 10 LogTest cases failed for file.renameTo failed under windows

2015-08-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705922#comment-14705922 ] ASF GitHub Bot commented on KAFKA-2170: --- GitHub user mpoindexter opened a pull reque

[GitHub] kafka pull request: KAFKA-2170, KAFKA-1194: Fixes for Windows

2015-08-20 Thread mpoindexter
GitHub user mpoindexter opened a pull request: https://github.com/apache/kafka/pull/154 KAFKA-2170, KAFKA-1194: Fixes for Windows This branch fixes several Windows specific issues, both in the code and in the tests. With these changes the whole test suite passes on my Windows mach

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

2015-08-20 Thread Parth Brahmbhatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705917#comment-14705917 ] Parth Brahmbhatt commented on KAFKA-873: Sorry, i misunderstood the original questi

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

2015-08-20 Thread Edward Ribeiro (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705911#comment-14705911 ] Edward Ribeiro commented on KAFKA-873: -- Sorry, I didn't follow here. Guava is not alre

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

2015-08-20 Thread Edward Ribeiro (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705909#comment-14705909 ] Edward Ribeiro commented on KAFKA-873: -- Sorry, I didn't follow here. Guava is not alre

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

2015-08-20 Thread Parth Brahmbhatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705899#comment-14705899 ] Parth Brahmbhatt commented on KAFKA-873: you could, but then any client who relied

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

2015-08-20 Thread Flavio Junqueira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705842#comment-14705842 ] Flavio Junqueira commented on KAFKA-873: can we use shading to solve this problem?

[jira] [Updated] (KAFKA-1901) Move Kafka version to be generated in code by build (instead of in manifest)

2015-08-20 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy updated KAFKA-1901: -- Resolution: Fixed Status: Resolved (was: Patch Available) Thanks for the patch - committed to t

Re: Review Request 35867: Patch for KAFKA-1901

2015-08-20 Thread Joel Koshy
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35867/#review96003 --- Ship it! Ship It! - Joel Koshy On Aug. 20, 2015, 7:08 a.m., Mani

[jira] [Updated] (KAFKA-2015) Enable ConsoleConsumer to use new consumer

2015-08-20 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2015: - Resolution: Fixed Fix Version/s: (was: 0.9.0) 0.8.3 Status

[jira] [Commented] (KAFKA-2015) Enable ConsoleConsumer to use new consumer

2015-08-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705664#comment-14705664 ] ASF GitHub Bot commented on KAFKA-2015: --- Github user asfgit closed the pull request

[GitHub] kafka pull request: KAFKA-2015: Enable ConsoleConsumer to use new ...

2015-08-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/144 --- 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 enabl

[jira] [Updated] (KAFKA-1651) Removed some extra whitespace in KafkaServer.scala

2015-08-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-1651: --- Resolution: Fixed Status: Resolved (was: Patch Available) These unwanted white-spaces

[jira] [Commented] (KAFKA-1683) Implement a "session" concept in the socket server

2015-08-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705540#comment-14705540 ] Gwen Shapira commented on KAFKA-1683: - I think I'm good, expect a patch by Friday. >

[jira] [Commented] (KAFKA-1683) Implement a "session" concept in the socket server

2015-08-20 Thread Parth Brahmbhatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705538#comment-14705538 ] Parth Brahmbhatt commented on KAFKA-1683: - [~gwenshap] Given this blocks KAFKA-221

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

2015-08-20 Thread Parth Brahmbhatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705537#comment-14705537 ] Parth Brahmbhatt commented on KAFKA-2210: - [~ijuma] [~junrao] Thanks for the revie

[jira] [Assigned] (KAFKA-2452) enable new consumer in mirror maker

2015-08-20 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned KAFKA-2452: --- Assignee: Jiangjie Qin > enable new consumer in mirror maker > --

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

2015-08-20 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705513#comment-14705513 ] Jay Kreps commented on KAFKA-873: - Curator will add a transitive dependency on Guava for th

Re: Review Request 34492: Patch for KAFKA-2210

2015-08-20 Thread Parth Brahmbhatt
> On Aug. 20, 2015, 10:30 a.m., Ismael Juma wrote: > > One more thing: it may be a good idea to rebase against trunk since the > > large SSL/TLS patch has now been merged (not sure if there are any > > conflicts). Done. - Parth --- Th

Re: Review Request 34492: Patch for KAFKA-2210

2015-08-20 Thread Parth Brahmbhatt
> On Aug. 20, 2015, 1:07 a.m., Jun Rao wrote: > > core/src/main/scala/kafka/security/auth/Acl.scala, lines 84-87 > > > > > > Do we need the case match here since acls is always a Set? Fixed. > On Aug. 20, 2015, 1:

[jira] [Updated] (KAFKA-2454) Dead lock between delete log segment and shutting down.

2015-08-20 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2454: Status: Patch Available (was: Open) > Dead lock between delete log segment and shutting down. > ---

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

2015-08-20 Thread Parth Brahmbhatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Parth Brahmbhatt updated KAFKA-2210: Status: Patch Available (was: In Progress) > KafkaAuthorizer: Add all public entities, conf

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

2015-08-20 Thread Parth Brahmbhatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705505#comment-14705505 ] Parth Brahmbhatt commented on KAFKA-2210: - Updated reviewboard https://reviews.apa

Re: Review Request 34492: Patch for KAFKA-2210

2015-08-20 Thread Parth Brahmbhatt
> On Aug. 20, 2015, 10:29 a.m., Ismael Juma wrote: > > core/src/main/scala/kafka/network/RequestChannel.scala, line 48 > > > > > > Normally one would use `Option[Session]` here. Are we using `null` due > > to effici

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

2015-08-20 Thread Parth Brahmbhatt (JIRA)
[ 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-20_11:27:18.patch > KafkaAuthorizer: Add all public entities,

Re: Review Request 34492: Patch for KAFKA-2210

2015-08-20 Thread Parth Brahmbhatt
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34492/ --- (Updated Aug. 20, 2015, 6:27 p.m.) Review request for kafka. Bugs: KAFKA-2210

[GitHub] kafka pull request: KAFKA-2454: Deadlock between log segment delet...

2015-08-20 Thread becketqin
GitHub user becketqin opened a pull request: https://github.com/apache/kafka/pull/153 KAFKA-2454: Deadlock between log segment deletion and server shutdown. You can merge this pull request into a Git repository by running: $ git pull https://github.com/becketqin/kafka KAFKA-24

[jira] [Commented] (KAFKA-2454) Dead lock between delete log segment and shutting down.

2015-08-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705491#comment-14705491 ] ASF GitHub Bot commented on KAFKA-2454: --- GitHub user becketqin opened a pull request

Re: KAFKA-2364 migrate docs from SVN to git

2015-08-20 Thread Manikumar Reddy
Also can we migrate svn repo to git repo? This will help us to fix occasional doc changes/bug fixes through github PR. On Thu, Aug 20, 2015 at 4:04 AM, Guozhang Wang wrote: > Gwen: I remembered it wrong. We would not need another round of voting. > > On Wed, Aug 19, 2015 at 3:06 PM, Gwen Shap

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

2015-08-20 Thread Edward Ribeiro (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705442#comment-14705442 ] Edward Ribeiro commented on KAFKA-873: -- [~granthenke], [~fpj], [~ijuma] Please, count

[jira] [Created] (KAFKA-2454) Dead lock between delete log segment and shutting down.

2015-08-20 Thread Jiangjie Qin (JIRA)
Jiangjie Qin created KAFKA-2454: --- Summary: Dead lock between delete log segment and shutting down. Key: KAFKA-2454 URL: https://issues.apache.org/jira/browse/KAFKA-2454 Project: Kafka Issue Typ

[jira] [Commented] (KAFKA-2015) Enable ConsoleConsumer to use new consumer

2015-08-20 Thread Ben Stopford (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705310#comment-14705310 ] Ben Stopford commented on KAFKA-2015: - I think we should move this to 0.8.3? It would

[jira] [Commented] (KAFKA-2453) enable new consumer in EndToEndLatency

2015-08-20 Thread Ben Stopford (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705257#comment-14705257 ] Ben Stopford commented on KAFKA-2453: - Yep - I'm on it > enable new consumer in EndT

[jira] [Assigned] (KAFKA-2453) enable new consumer in EndToEndLatency

2015-08-20 Thread Ben Stopford (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Stopford reassigned KAFKA-2453: --- Assignee: Ben Stopford > enable new consumer in EndToEndLatency > ---

[jira] [Commented] (KAFKA-2453) enable new consumer in EndToEndLatency

2015-08-20 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705251#comment-14705251 ] Ismael Juma commented on KAFKA-2453: I think [~benstopford] was going to look into thi

[jira] [Created] (KAFKA-2453) enable new consumer in EndToEndLatency

2015-08-20 Thread Jun Rao (JIRA)
Jun Rao created KAFKA-2453: -- Summary: enable new consumer in EndToEndLatency Key: KAFKA-2453 URL: https://issues.apache.org/jira/browse/KAFKA-2453 Project: Kafka Issue Type: Sub-task Rep

[jira] [Created] (KAFKA-2452) enable new consumer in mirror maker

2015-08-20 Thread Jun Rao (JIRA)
Jun Rao created KAFKA-2452: -- Summary: enable new consumer in mirror maker Key: KAFKA-2452 URL: https://issues.apache.org/jira/browse/KAFKA-2452 Project: Kafka Issue Type: Sub-task Componen

[jira] [Commented] (KAFKA-1695) Authenticate connection to Zookeeper

2015-08-20 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705218#comment-14705218 ] Ismael Juma commented on KAFKA-1695: [~parth.brahmbhatt], yeah, you can close and reop

[jira] [Commented] (KAFKA-2387) Improve KafkaConsumer API

2015-08-20 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705214#comment-14705214 ] Jun Rao commented on KAFKA-2387: Linking this to the new consumer umbrella jira. > Improv

[jira] [Commented] (KAFKA-1695) Authenticate connection to Zookeeper

2015-08-20 Thread Parth Brahmbhatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705211#comment-14705211 ] Parth Brahmbhatt commented on KAFKA-1695: - [~junrao] This is the patch https://git

[jira] [Commented] (KAFKA-1695) Authenticate connection to Zookeeper

2015-08-20 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705208#comment-14705208 ] Ismael Juma commented on KAFKA-1695: [~junrao], it's a PR: https://github.com/apache/

[jira] [Commented] (KAFKA-1695) Authenticate connection to Zookeeper

2015-08-20 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705201#comment-14705201 ] Jun Rao commented on KAFKA-1695: [~parth.brahmbhatt], is there actually a patch to review

[jira] [Commented] (KAFKA-2411) remove usage of BlockingChannel in the broker

2015-08-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705145#comment-14705145 ] ASF GitHub Bot commented on KAFKA-2411: --- GitHub user ijuma reopened a pull request:

[jira] [Commented] (KAFKA-2411) remove usage of BlockingChannel in the broker

2015-08-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705144#comment-14705144 ] ASF GitHub Bot commented on KAFKA-2411: --- Github user ijuma closed the pull request a

[GitHub] kafka pull request: KAFKA-2411; remove usage of blocking channel

2015-08-20 Thread ijuma
Github user ijuma closed the pull request at: https://github.com/apache/kafka/pull/151 --- 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 enable

[GitHub] kafka pull request: KAFKA-2411; remove usage of blocking channel

2015-08-20 Thread ijuma
GitHub user ijuma reopened a pull request: https://github.com/apache/kafka/pull/151 KAFKA-2411; remove usage of blocking channel You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka kafka-2411-remove-usage-of-blocking-cha

[jira] [Created] (KAFKA-2451) Exception logged but not managed

2015-08-20 Thread JIRA
Gwenhaƫl PASQUIERS created KAFKA-2451: - Summary: Exception logged but not managed Key: KAFKA-2451 URL: https://issues.apache.org/jira/browse/KAFKA-2451 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

2015-08-20 Thread Flavio Junqueira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705096#comment-14705096 ] Flavio Junqueira commented on KAFKA-873: ZkClient is used in a number of places acr

[jira] [Updated] (KAFKA-2411) remove usage of BlockingChannel in the broker

2015-08-20 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2411: --- Status: Patch Available (was: In Progress) Addressed feedback from Gwen, so setting status to "Patch

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

2015-08-20 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705071#comment-14705071 ] Ismael Juma commented on KAFKA-873: --- Would there be an advantage to going to the bridge f

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-08-20 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705068#comment-14705068 ] nicu marasoiu commented on KAFKA-1282: -- Hi, I noticed that the dependencies are done

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

2015-08-20 Thread Flavio Junqueira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705044#comment-14705044 ] Flavio Junqueira commented on KAFKA-873: Ah! That's what I was looking for, thanks

[jira] [Comment Edited] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

2015-08-20 Thread Jordan Zimmerman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705003#comment-14705003 ] Jordan Zimmerman edited comment on KAFKA-873 at 8/20/15 2:30 PM:

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

2015-08-20 Thread Jordan Zimmerman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705003#comment-14705003 ] Jordan Zimmerman commented on KAFKA-873: NOTE: Curator's PersistenEphemeralNode wou

Re: Review Request 34492: Patch for KAFKA-2210

2015-08-20 Thread Jun Rao
> On Aug. 20, 2015, 10:29 a.m., Ismael Juma wrote: > > core/src/main/scala/kafka/security/auth/Operation.scala, line 42 > > > > > > Generally a good idea to set the result type for public methods. This > > makes it

[jira] [Commented] (KAFKA-2295) Dynamically loaded classes (encoders, etc.) may not be found by Kafka Producer

2015-08-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14704757#comment-14704757 ] Manikumar Reddy commented on KAFKA-2295: [~guozhang] Can we go ahead and commit t

[jira] [Commented] (KAFKA-2295) Dynamically loaded classes (encoders, etc.) may not be found by Kafka Producer

2015-08-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14704749#comment-14704749 ] Manikumar Reddy commented on KAFKA-2295: Updated reviewboard https://reviews.apach

[jira] [Updated] (KAFKA-2295) Dynamically loaded classes (encoders, etc.) may not be found by Kafka Producer

2015-08-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2295: --- Attachment: KAFKA-2295_2015-08-20_17:44:56.patch > Dynamically loaded classes (encoders, etc.)

Re: Review Request 35880: Patch for KAFKA-2295

2015-08-20 Thread Manikumar Reddy O
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35880/ --- (Updated Aug. 20, 2015, 12:17 p.m.) Review request for kafka. Bugs: KAFKA-229

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

2015-08-20 Thread Flavio Junqueira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14704731#comment-14704731 ] Flavio Junqueira commented on KAFKA-873: [~granthenke] I'm more than happy to let y

[jira] [Commented] (KAFKA-2213) Log cleaner should write compacted messages using configured compression type

2015-08-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14704713#comment-14704713 ] Manikumar Reddy commented on KAFKA-2213: Updated reviewboard https://reviews.apach

[jira] [Updated] (KAFKA-2213) Log cleaner should write compacted messages using configured compression type

2015-08-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2213: --- Attachment: KAFKA-2213_2015-08-20_17:04:28.patch > Log cleaner should write compacted messages

  1   2   >