[jira] [Created] (KAFKA-2724) ZooKeeper authentication documentation

Flavio Junqueira created KAFKA-2724: --- Summary: ZooKeeper authentication documentation Key: KAFKA-2724 URL: https://issues.apache.org/jira/browse/KAFKA-2724 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-2724) Document ZooKeeper authentication

[ https://issues.apache.org/jira/browse/KAFKA-2724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-2724: Summary: Document ZooKeeper authentication (was: ZooKeeper authentication documentation )

SSL authorization mechanizm

Hi, My company is currently looking at Kafka as message broker. One of key aspects is security. I'm currently looking at authentication/authorization mechanisms in Kafka 0.9.0.0-SNAPSHOT. We have decided that SSL based authentication/authorization will be sufficient for us at the begging. We

unsubcribe

[jira] [Commented] (KAFKA-2724) Document ZooKeeper authentication

[ https://issues.apache.org/jira/browse/KAFKA-2724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985606#comment-14985606 ] Flavio Junqueira commented on KAFKA-2724: - A security.html file is being introduced in KAFKA-2681,

[jira] [Resolved] (KAFKA-2255) Missing documentation for max.in.flight.requests.per.connection

[ https://issues.apache.org/jira/browse/KAFKA-2255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2255. - Resolution: Fixed > Missing documentation for max.in.flight.requests.per.connection >

[jira] [Commented] (KAFKA-2255) Missing documentation for max.in.flight.requests.per.connection

[ https://issues.apache.org/jira/browse/KAFKA-2255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985657#comment-14985657 ] Gwen Shapira commented on KAFKA-2255: - Actually, for 0.9.0.0 we will automatically generate the docs

[jira] [Commented] (KAFKA-2658) Implement SASL/PLAIN

[ https://issues.apache.org/jira/browse/KAFKA-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985663#comment-14985663 ] Jun Rao commented on KAFKA-2658: [~rsivaram], we had a chat with a security consulting firm last week. It

[jira] [Commented] (KAFKA-2441) SSL/TLS in official docs

[ https://issues.apache.org/jira/browse/KAFKA-2441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985672#comment-14985672 ] Gwen Shapira commented on KAFKA-2441: - [~harsha_ch], if you are busy, mind if I pick this one too? >

[GitHub] kafka pull request: KAFKA-2722: Improve ISR change propagation.

GitHub user becketqin reopened a pull request: https://github.com/apache/kafka/pull/402 KAFKA-2722: Improve ISR change propagation. The patch has two changes: 1. fixed a bug in controller that it sends UpdateMetadataRequest of all the partitions in the cluster. 2. Uses the

[GitHub] kafka pull request: Improve ISR change propagation.

GitHub user becketqin reopened a pull request: https://github.com/apache/kafka/pull/402 Improve ISR change propagation. The patch has two changes: 1. fixed a bug in controller that it sends UpdateMetadataRequest of all the partitions in the cluster. 2. Uses the following

[GitHub] kafka pull request: KAFKA-2722: Improve ISR change propagation.

Github user becketqin closed the pull request at: https://github.com/apache/kafka/pull/402 --- 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

[jira] [Commented] (KAFKA-2681) SASL authentication in official docs

[ https://issues.apache.org/jira/browse/KAFKA-2681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985669#comment-14985669 ] ASF GitHub Bot commented on KAFKA-2681: --- Github user asfgit closed the pull request at:

[jira] [Updated] (KAFKA-2681) SASL authentication in official docs

[ https://issues.apache.org/jira/browse/KAFKA-2681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2681: Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

Build failed in Jenkins: kafka-trunk-jdk7 #744

See Changes: [cshapi] KAFKA-2681: Added SASL documentation -- [...truncated 67 lines...] ^

[jira] [Updated] (KAFKA-2687) Add support for ListGroups and DescribeGroup APIs

[ https://issues.apache.org/jira/browse/KAFKA-2687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2687: --- Reviewer: Jun Rao > Add support for ListGroups and DescribeGroup APIs >

[jira] [Updated] (KAFKA-2722) Improve ISR change propagation

[ https://issues.apache.org/jira/browse/KAFKA-2722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2722: Priority: Blocker (was: Major) > Improve ISR change propagation > -- >

[GitHub] kafka pull request: Improve ISR change propagation.

Github user becketqin closed the pull request at: https://github.com/apache/kafka/pull/402 --- 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

[jira] [Commented] (KAFKA-2722) Improve ISR change propagation

[ https://issues.apache.org/jira/browse/KAFKA-2722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985686#comment-14985686 ] ASF GitHub Bot commented on KAFKA-2722: --- Github user becketqin closed the pull request at:

[jira] [Commented] (KAFKA-2722) Improve ISR change propagation

[ https://issues.apache.org/jira/browse/KAFKA-2722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985687#comment-14985687 ] ASF GitHub Bot commented on KAFKA-2722: --- GitHub user becketqin reopened a pull request:

[jira] [Commented] (KAFKA-2580) Kafka Broker keeps file handles open for all log files (even if its not written to/read from)

[ https://issues.apache.org/jira/browse/KAFKA-2580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985707#comment-14985707 ] Vinoth Chandar commented on KAFKA-2580: --- [~jkreps] ah ok. point taken :) > Kafka Broker keeps file

[jira] [Commented] (KAFKA-2716) Make Kafka core not depend on log4j-appender

[ https://issues.apache.org/jira/browse/KAFKA-2716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985750#comment-14985750 ] Ashish K Singh commented on KAFKA-2716: --- [~ijuma], [~gwenshap] I agree that not breaking existing

[jira] [Commented] (KAFKA-2658) Implement SASL/PLAIN

[ https://issues.apache.org/jira/browse/KAFKA-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985751#comment-14985751 ] Rajini Sivaram commented on KAFKA-2658: --- [~junrao] As described in the RFC for SASL/PLAIN

Re: 0.9.0 release branch

I added KAFKA-2691 as well, which improves client handling of authorization errors. -Jason On Mon, Nov 2, 2015 at 10:25 AM, Becket Qin wrote: > Hi Jun, > > I added KAFKA-2722 as a blocker for 0.9. It fixes the ISR propagation > scalability issue we saw. > > Thanks, > >

[GitHub] kafka pull request: KAFKA-2681: Added SASL documentation. It doesn...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/401 --- 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

Re: 0.9.0 release branch

Hi Jun, I added KAFKA-2722 as a blocker for 0.9. It fixes the ISR propagation scalability issue we saw. Thanks, Jiangjie (Becket) Qin On Mon, Nov 2, 2015 at 9:16 AM, Jun Rao wrote: > Hi, everyone, > > We are getting close to the 0.9.0 release. The current plan is to have

[jira] [Commented] (KAFKA-2580) Kafka Broker keeps file handles open for all log files (even if its not written to/read from)

[ https://issues.apache.org/jira/browse/KAFKA-2580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985696#comment-14985696 ] Jay Kreps commented on KAFKA-2580: -- [~vinothchandar] All I'm saying is that you have to kind of do some

[jira] [Resolved] (KAFKA-2528) Quota Performance Evaluation

[ https://issues.apache.org/jira/browse/KAFKA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-2528. - Resolution: Fixed > Quota Performance Evaluation > > > Key:

[GitHub] kafka pull request: KAFKA-2716: Make Kafka core not depend on log4...

GitHub user SinghAsDev opened a pull request: https://github.com/apache/kafka/pull/405 KAFKA-2716: Make Kafka core not depend on log4j-appender You can merge this pull request into a Git repository by running: $ git pull https://github.com/SinghAsDev/kafka KAFKA-2716

[jira] [Updated] (KAFKA-2691) Improve handling of authorization failure during metadata refresh

[ https://issues.apache.org/jira/browse/KAFKA-2691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2691: --- Priority: Blocker (was: Major) > Improve handling of authorization failure during metadata

[jira] [Commented] (KAFKA-2716) Make Kafka core not depend on log4j-appender

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

[jira] [Updated] (KAFKA-2722) Improve ISR change propagation

[ https://issues.apache.org/jira/browse/KAFKA-2722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2722: Fix Version/s: 0.9.0.0 > Improve ISR change propagation > -- > >

[jira] [Commented] (KAFKA-2441) SSL/TLS in official docs

[ https://issues.apache.org/jira/browse/KAFKA-2441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985681#comment-14985681 ] Sriharsha Chintalapani commented on KAFKA-2441: --- [~gwenshap] Please go ahead. Thanks. >

[jira] [Commented] (KAFKA-2528) Quota Performance Evaluation

[ https://issues.apache.org/jira/browse/KAFKA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985697#comment-14985697 ] Jay Kreps commented on KAFKA-2528: -- [~lindong] Great! > Quota Performance Evaluation >

[GitHub] kafka pull request: KAFKA-2017: Persist Group Metadata and Assignm...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/386 --- 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

Build failed in Jenkins: kafka-trunk-jdk7 #748

See Changes: [wangguoz] KAFKA-2017: Persist Group Metadata and Assignment before Responding -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on

[jira] [Commented] (KAFKA-2017) Persist Coordinator State for Coordinator Failover

[ https://issues.apache.org/jira/browse/KAFKA-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14986850#comment-14986850 ] ASF GitHub Bot commented on KAFKA-2017: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (KAFKA-2018) Add metadata to consumer registry info

[ https://issues.apache.org/jira/browse/KAFKA-2018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2018. -- Resolution: Fixed This is solved as part of KAFKA-2017. > Add metadata to consumer registry

[jira] [Updated] (KAFKA-2017) Persist Coordinator State for Coordinator Failover

[ https://issues.apache.org/jira/browse/KAFKA-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2017: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (KAFKA-2018) Add metadata to consumer registry info

[ https://issues.apache.org/jira/browse/KAFKA-2018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2018: - Fix Version/s: (was: 0.10.0.0) 0.9.0.0 > Add metadata to consumer registry

[jira] [Commented] (KAFKA-2698) add paused API

[ https://issues.apache.org/jira/browse/KAFKA-2698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14986776#comment-14986776 ] Jun Rao commented on KAFKA-2698: [~guozhang], is this an 0.9.0 blocker? > add paused API > --

[jira] [Updated] (KAFKA-2518) Update NOTICE file

[ https://issues.apache.org/jira/browse/KAFKA-2518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2518: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Commented] (KAFKA-2518) Update NOTICE file

[ https://issues.apache.org/jira/browse/KAFKA-2518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985792#comment-14985792 ] ASF GitHub Bot commented on KAFKA-2518: --- Github user asfgit closed the pull request at:

[jira] [Updated] (KAFKA-2580) Kafka Broker keeps file handles open for all log files (even if its not written to/read from)

[ https://issues.apache.org/jira/browse/KAFKA-2580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-2580: --- Assignee: (was: Grant Henke) > Kafka Broker keeps file handles open for all log files (even if

[jira] [Commented] (KAFKA-2658) Implement SASL/PLAIN

[ https://issues.apache.org/jira/browse/KAFKA-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985939#comment-14985939 ] Jun Rao commented on KAFKA-2658: [~rsivaram], yes, perhaps enforcing that SASL/PLAIN can only be used with

[jira] [Commented] (KAFKA-2441) SSL/TLS in official docs

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

Re: 0.9.0 release branch

Hi Jun, I openned KAFKA-2725 based on my experience with duplicate message processing with auto-commit off. I think it's a fairly small change, especially for someone familiar with the kafka code-base but it makes a big impact for clients not using auto-commit. Can this be included in 0.9.0?

[GitHub] kafka pull request: KAFKA-2441: SSL/TLS in official docs

GitHub user gwenshap opened a pull request: https://github.com/apache/kafka/pull/406 KAFKA-2441: SSL/TLS in official docs You can merge this pull request into a Git repository by running: $ git pull https://github.com/gwenshap/kafka KAFKA-2441 Alternatively you can review

[GitHub] kafka pull request: KAFKA-2518: Update NOTICE file

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/404 --- 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

[jira] [Commented] (KAFKA-2719) Kafka classpath has grown too large and breaks some system tests

[ https://issues.apache.org/jira/browse/KAFKA-2719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985813#comment-14985813 ] Geoff Anderson commented on KAFKA-2719: --- [~rsivaram] I wonder if this problem is better addressed in

[jira] [Commented] (KAFKA-2723) Standardize new consumer exceptions

[ https://issues.apache.org/jira/browse/KAFKA-2723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985921#comment-14985921 ] Guozhang Wang commented on KAFKA-2723: -- Thanks [~hachikuji], a few clarification questions: 1)

[jira] [Updated] (KAFKA-2441) SSL/TLS in official docs

[ https://issues.apache.org/jira/browse/KAFKA-2441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2441: Status: Patch Available (was: Open) > SSL/TLS in official docs > > >

Build failed in Jenkins: kafka-trunk-jdk8 #85

See Changes: [cshapi] KAFKA-2681: Added SASL documentation [wangguoz] KAFKA-2518: Update NOTICE file -- Started by an SCM change [EnvInject] - Loading node environment variables. Building

[jira] [Commented] (KAFKA-2580) Kafka Broker keeps file handles open for all log files (even if its not written to/read from)

[ https://issues.apache.org/jira/browse/KAFKA-2580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985875#comment-14985875 ] Grant Henke commented on KAFKA-2580: Marking as Unassigned as I need to shift my focus to some other

[jira] [Commented] (KAFKA-2719) Kafka classpath has grown too large and breaks some system tests

[ https://issues.apache.org/jira/browse/KAFKA-2719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985881#comment-14985881 ] Rajini Sivaram commented on KAFKA-2719: --- [~geoffra] If system tests are guaranteed to start only one

Build failed in Jenkins: kafka-trunk-jdk7 #745

See Changes: [wangguoz] KAFKA-2518: Update NOTICE file -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-2 (docker Ubuntu ubuntu) in

[jira] [Created] (KAFKA-2725) high level consumer rebalances with auto-commit disabled should throw an exception

Cliff Rhyne created KAFKA-2725: -- Summary: high level consumer rebalances with auto-commit disabled should throw an exception Key: KAFKA-2725 URL: https://issues.apache.org/jira/browse/KAFKA-2725

[jira] [Commented] (KAFKA-2726) ntpdate causes vagrant provision to fail if ntp running

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

[jira] [Commented] (KAFKA-2698) add paused API

[ https://issues.apache.org/jira/browse/KAFKA-2698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14986779#comment-14986779 ] Guozhang Wang commented on KAFKA-2698: -- I think it is OK to not include this ticket; on the other

[jira] [Commented] (KAFKA-2702) ConfigDef toHtmlTable() sorts in a way that is a bit confusing

[ https://issues.apache.org/jira/browse/KAFKA-2702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14986744#comment-14986744 ] Jun Rao commented on KAFKA-2702: [~granthenke], we can probably do the following. 1. Remove the required

Re: SSL authorization mechanizm

Yes, by default, we take the full ssl certificate attributes as the user name. This may not be suitable for ACL. We do allow the ssl user name to be customized through PrincipalBuilder. You can define a customized PrincipalBuilder and pass that in through "principal.builder.class". The customized

[jira] [Commented] (KAFKA-2518) Update NOTICE file

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

[jira] [Updated] (KAFKA-2724) Document ZooKeeper authentication

[ https://issues.apache.org/jira/browse/KAFKA-2724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2724: --- Affects Version/s: 0.9.0.0 Fix Version/s: 0.9.0.0 > Document ZooKeeper authentication >

[jira] [Assigned] (KAFKA-2518) Update NOTICE file

[ https://issues.apache.org/jira/browse/KAFKA-2518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira reassigned KAFKA-2518: --- Assignee: Gwen Shapira > Update NOTICE file > -- > > Key:

[jira] [Updated] (KAFKA-2518) Update NOTICE file

[ https://issues.apache.org/jira/browse/KAFKA-2518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2518: Status: Patch Available (was: Open) > Update NOTICE file > -- > >

0.9.0 release branch

Hi, everyone, We are getting close to the 0.9.0 release. The current plan is to have the following remaining 0.9.0 blocker issues resolved this week, cut the 0.9.0 release branch by Nov. 6 (Friday) and start the RC on Nov. 9 (Monday).

[jira] [Updated] (KAFKA-2681) SASL authentication in official docs

[ https://issues.apache.org/jira/browse/KAFKA-2681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2681: Status: Patch Available (was: Open) > SASL authentication in official docs >

[GitHub] kafka pull request: KAFKA-2518: Update NOTICE file

GitHub user gwenshap opened a pull request: https://github.com/apache/kafka/pull/404 KAFKA-2518: Update NOTICE file You can merge this pull request into a Git repository by running: $ git pull https://github.com/gwenshap/kafka KAFKA-2518 Alternatively you can review and

[GitHub] kafka pull request: KAFKA-2706: make state stores first class citi...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/387 --- 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

[jira] [Commented] (KAFKA-2726) ntpdate causes vagrant provision to fail if ntp running

[ https://issues.apache.org/jira/browse/KAFKA-2726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14986155#comment-14986155 ] ASF GitHub Bot commented on KAFKA-2726: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-2719) Kafka classpath has grown too large and breaks some system tests

[ https://issues.apache.org/jira/browse/KAFKA-2719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14986056#comment-14986056 ] Geoff Anderson commented on KAFKA-2719: --- [~rsivaram] Unfortunately we don't have this guarantee, for

[GitHub] kafka pull request: KAFKA-2707: make KStream processor names deter...

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/408 KAFKA-2707: make KStream processor names deterministic @guozhangwang You can merge this pull request into a Git repository by running: $ git pull https://github.com/ymatsuda/kafka

[jira] [Resolved] (KAFKA-2726) ntpdate causes vagrant provision to fail if ntp running

[ https://issues.apache.org/jira/browse/KAFKA-2726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2726. -- Resolution: Fixed Fix Version/s: 0.9.0.0 Issue resolved by pull request 407

[GitHub] kafka pull request: KAFKA-2726: Fix port collision between ntpdate...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/407 --- 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

[jira] [Resolved] (KAFKA-2706) Make state stores first class citizens in the processor DAG

[ https://issues.apache.org/jira/browse/KAFKA-2706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2706. -- Resolution: Fixed Fix Version/s: 0.9.0.0 Issue resolved by pull request 387

[jira] [Commented] (KAFKA-2706) Make state stores first class citizens in the processor DAG

[ https://issues.apache.org/jira/browse/KAFKA-2706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14986076#comment-14986076 ] ASF GitHub Bot commented on KAFKA-2706: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-2707) Make KStream processor names deterministic

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

[jira] [Commented] (KAFKA-1694) kafka command line and centralized operations

[ https://issues.apache.org/jira/browse/KAFKA-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14984933#comment-14984933 ] Andrii Biletskyi commented on KAFKA-1694: - [~granthenke], it was decided to split the work into 3

[GitHub] kafka pull request: KAFKA-2724: ZK Auth documentation.

GitHub user fpj opened a pull request: https://github.com/apache/kafka/pull/409 KAFKA-2724: ZK Auth documentation. You can merge this pull request into a Git repository by running: $ git pull https://github.com/fpj/kafka KAFKA-2724 Alternatively you can review and apply

[jira] [Commented] (KAFKA-2724) Document ZooKeeper authentication

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

Build failed in Jenkins: kafka-trunk-jdk7 #747

See Changes: [wangguoz] KAFKA-2726: Fix port collision between ntpdate and ntp daemon [wangguoz] KAFKA-2707: make KStream processor names deterministic -- [...truncated 37 lines...]

Build failed in Jenkins: kafka-trunk-jdk8 #86

See Changes: [wangguoz] KAFKA-2706: make state stores first class citizens in the processor [wangguoz] KAFKA-2726: Fix port collision between ntpdate and ntp daemon -- [...truncated 3773

[jira] [Created] (KAFKA-2727) initialize only the part of the topology relevant to the task

Yasuhiro Matsuda created KAFKA-2727: --- Summary: initialize only the part of the topology relevant to the task Key: KAFKA-2727 URL: https://issues.apache.org/jira/browse/KAFKA-2727 Project: Kafka

[jira] [Updated] (KAFKA-2724) Document ZooKeeper authentication

[ https://issues.apache.org/jira/browse/KAFKA-2724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2724: Status: Patch Available (was: Open) > Document ZooKeeper authentication >

[jira] [Updated] (KAFKA-2722) Improve ISR change propagation

[ https://issues.apache.org/jira/browse/KAFKA-2722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2722: Status: Patch Available (was: Open) > Improve ISR change propagation >

[jira] [Updated] (KAFKA-2707) Make KStream processor names deterministic

[ https://issues.apache.org/jira/browse/KAFKA-2707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2707: - Assignee: Yasuhiro Matsuda > Make KStream processor names deterministic >

[jira] [Commented] (KAFKA-2707) Make KStream processor names deterministic

[ https://issues.apache.org/jira/browse/KAFKA-2707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14986183#comment-14986183 ] ASF GitHub Bot commented on KAFKA-2707: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-2697) add leave group logic to the consumer

[ https://issues.apache.org/jira/browse/KAFKA-2697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14986229#comment-14986229 ] Guozhang Wang commented on KAFKA-2697: -- [~onurkaraman] assigning the ticket to you now, please let me

[jira] [Updated] (KAFKA-2697) add leave group logic to the consumer

[ https://issues.apache.org/jira/browse/KAFKA-2697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2697: - Assignee: Onur Karaman > add leave group logic to the consumer >

Build failed in Jenkins: kafka-trunk-jdk8 #87

See Changes: [wangguoz] KAFKA-2707: make KStream processor names deterministic -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (Ubuntu

Re: 0.9.0 release branch

I added KAFKA-2698 as an 0.9.0.0 blocker. It adds an API to query the currently paused partitions. Here's the PR: https://github.com/apache/kafka/pull/403 On Mon, Nov 2, 2015 at 11:16 AM, Cliff Rhyne wrote: > Hi Jun, > > I

[GitHub] kafka pull request: Modified the async producer so it re-queues fa...

Github user hiloboy0119 closed the pull request at: https://github.com/apache/kafka/pull/7 --- 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

[GitHub] kafka pull request: KAFKA-2707: make KStream processor names deter...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/408 --- 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

[jira] [Resolved] (KAFKA-2707) Make KStream processor names deterministic

[ https://issues.apache.org/jira/browse/KAFKA-2707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2707. -- Resolution: Fixed Fix Version/s: 0.9.0.0 Issue resolved by pull request 408

Jenkins build is back to normal : kafka-trunk-jdk7 #746

See

[jira] [Updated] (KAFKA-2698) add paused API

[ https://issues.apache.org/jira/browse/KAFKA-2698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman updated KAFKA-2698: Priority: Blocker (was: Major) > add paused API > -- > > Key:

Re: 0.9.0 release branch

Cliff, We try not to patch the old consumer too much since we are adding the new java consumer in 0.9. The new consumer supports callbacks during rebalances and can address the problem in KAFKA-2725 better. Thanks, Jun On Mon, Nov 2, 2015 at 11:16 AM, Cliff Rhyne wrote: >

[jira] [Commented] (KAFKA-2674) ConsumerRebalanceListener.onPartitionsRevoked() is not called on consumer close

[ https://issues.apache.org/jira/browse/KAFKA-2674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14986470#comment-14986470 ] Jason Gustafson commented on KAFKA-2674: [~guozhang] [~becket_qin] Since none of the alternatives

[jira] [Commented] (KAFKA-2702) ConfigDef toHtmlTable() sorts in a way that is a bit confusing

[ https://issues.apache.org/jira/browse/KAFKA-2702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14986371#comment-14986371 ] Grant Henke commented on KAFKA-2702: [~ijuma] I agree. This would be fairly simple in Scala, as Option

[jira] [Commented] (KAFKA-2255) Missing documentation for max.in.flight.requests.per.connection

[ https://issues.apache.org/jira/browse/KAFKA-2255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985117#comment-14985117 ] Stevo Slavic commented on KAFKA-2255: - Docs in code for this config property state: {quote} The

  1   2   >