[jira] [Created] (KAFKA-3384) bin scripts may not be portable/POSIX compliant

2016-03-10 Thread Ewen Cheslack-Postava (JIRA)
Ewen Cheslack-Postava created KAFKA-3384: Summary: bin scripts may not be portable/POSIX compliant Key: KAFKA-3384 URL: https://issues.apache.org/jira/browse/KAFKA-3384 Project: Kafka

[jira] [Work started] (KAFKA-3383) Producer should not remove an in flight request before successfully parsing the response.

2016-03-10 Thread chen zhu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3383 started by chen zhu. --- > Producer should not remove an in flight request before successfully parsing > the respon

[jira] [Commented] (KAFKA-3383) Producer should not remove an in flight request before successfully parsing the response.

2016-03-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15190441#comment-15190441 ] ASF GitHub Bot commented on KAFKA-3383: --- GitHub user zhuchen1018 opened a pull reque

[GitHub] kafka pull request: KAFKA-3383: remove in flight request only afte...

2016-03-10 Thread zhuchen1018
GitHub user zhuchen1018 opened a pull request: https://github.com/apache/kafka/pull/1050 KAFKA-3383: remove in flight request only after response parsing succeeds @becketqin, could you take a look at the patch? You can merge this pull request into a Git repository by running: $

[jira] [Updated] (KAFKA-3383) Producer should not remove an in flight request before successfully parsing the response.

2016-03-10 Thread chen zhu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chen zhu updated KAFKA-3383: Summary: Producer should not remove an in flight request before successfully parsing the response. (was: Pr

[jira] [Assigned] (KAFKA-3383) Producer should not remove an in flight requests before successfully parsing the response.

2016-03-10 Thread chen zhu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chen zhu reassigned KAFKA-3383: --- Assignee: chen zhu (was: Jiangjie Qin) > Producer should not remove an in flight requests before suc

[jira] [Commented] (KAFKA-3367) Delete topic dont delete the complete log from kafka

2016-03-10 Thread Mayuresh Gharat (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15190206#comment-15190206 ] Mayuresh Gharat commented on KAFKA-3367: The client that are producing to the kafk

[jira] [Commented] (KAFKA-3367) Delete topic dont delete the complete log from kafka

2016-03-10 Thread Akshath Patkar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15190185#comment-15190185 ] Akshath Patkar commented on KAFKA-3367: --- Yes, Automatic topic creation is turned on.

[jira] [Created] (KAFKA-3383) Producer should not remove an in flight requests before successfully parsing the response.

2016-03-10 Thread Jiangjie Qin (JIRA)
Jiangjie Qin created KAFKA-3383: --- Summary: Producer should not remove an in flight requests before successfully parsing the response. Key: KAFKA-3383 URL: https://issues.apache.org/jira/browse/KAFKA-3383

[jira] [Created] (KAFKA-3382) Add system test for ReplicationVerificationTool

2016-03-10 Thread Ashish K Singh (JIRA)
Ashish K Singh created KAFKA-3382: - Summary: Add system test for ReplicationVerificationTool Key: KAFKA-3382 URL: https://issues.apache.org/jira/browse/KAFKA-3382 Project: Kafka Issue Type: S

[jira] [Assigned] (KAFKA-3382) Add system test for ReplicationVerificationTool

2016-03-10 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh reassigned KAFKA-3382: - Assignee: Ashish K Singh > Add system test for ReplicationVerificationTool >

[jira] [Assigned] (KAFKA-3381) Add system test for SimpleConsumerShell

2016-03-10 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh reassigned KAFKA-3381: - Assignee: Ashish K Singh > Add system test for SimpleConsumerShell >

[jira] [Created] (KAFKA-3381) Add system test for SimpleConsumerShell

2016-03-10 Thread Ashish K Singh (JIRA)
Ashish K Singh created KAFKA-3381: - Summary: Add system test for SimpleConsumerShell Key: KAFKA-3381 URL: https://issues.apache.org/jira/browse/KAFKA-3381 Project: Kafka Issue Type: Sub-task

[GitHub] kafka pull request: MINOR: Add unit test for internal topics

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

Re: [DISCUSS] KIP-35 - Retrieve protocol version

2016-03-10 Thread Magnus Edenhill
Hey Jay, some thoughts in-line: 2016-03-04 18:52 GMT+01:00 Jay Kreps : > Yeah here is my summary of my take: > > 1. Negotiating a per-connection protocol actually does add a lot of > complexity to clients (many more failure states to get right). > I'm not sure about this. A client that needs t

[jira] [Updated] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

2016-03-10 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3373: Reviewer: Jun Rao > Add `log` prefix to KIP-31/32 configs > - >

[jira] [Updated] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

2016-03-10 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3373: Status: Patch Available (was: Open) > Add `log` prefix to KIP-31/32 configs > -

[jira] [Commented] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

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

[GitHub] kafka pull request: KAFKA-3373 add 'log' prefix to configurations ...

2016-03-10 Thread becketqin
GitHub user becketqin opened a pull request: https://github.com/apache/kafka/pull/1049 KAFKA-3373 add 'log' prefix to configurations in KIP-31/32 You can merge this pull request into a Git repository by running: $ git pull https://github.com/becketqin/kafka KAFKA-3373 Alterna

[jira] [Commented] (KAFKA-3380) Add system test for GetOffsetShell tool

2016-03-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15190015#comment-15190015 ] ASF GitHub Bot commented on KAFKA-3380: --- GitHub user SinghAsDev opened a pull reques

Re: [DISCUSS] KIP-35 - Retrieve protocol version

2016-03-10 Thread Magnus Edenhill
Hi all, sorry for joining late in the game, the carribean got in the way. My thoughts: There is no way around the chicken&egg problem, so the sooner we can add protocol versioning functionality the better and we'll add heuristics in clients to handle the migration period (e.g, what Dana has done

[GitHub] kafka pull request: KAFKA-3380: Add system test for GetOffsetShell...

2016-03-10 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request: https://github.com/apache/kafka/pull/1048 KAFKA-3380: Add system test for GetOffsetShell tool You can merge this pull request into a Git repository by running: $ git pull https://github.com/SinghAsDev/kafka KAFKA-3380 Alternativel

[jira] [Created] (KAFKA-3380) Add system test for GetOffsetShell tool

2016-03-10 Thread Ashish K Singh (JIRA)
Ashish K Singh created KAFKA-3380: - Summary: Add system test for GetOffsetShell tool Key: KAFKA-3380 URL: https://issues.apache.org/jira/browse/KAFKA-3380 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-3379) Update tools relying on old producer to use new producer.

2016-03-10 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3379: -- Description: Following tools are using old producer. * ReplicationVerificationTool * SimpleCons

[jira] [Created] (KAFKA-3379) Update tools relying on old producer to use new producer.

2016-03-10 Thread Ashish K Singh (JIRA)
Ashish K Singh created KAFKA-3379: - Summary: Update tools relying on old producer to use new producer. Key: KAFKA-3379 URL: https://issues.apache.org/jira/browse/KAFKA-3379 Project: Kafka Iss

[jira] [Commented] (KAFKA-3202) Add system test for KIP-31 and KIP-32 - Change message format version on the fly

2016-03-10 Thread Eno Thereska (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1519#comment-1519 ] Eno Thereska commented on KAFKA-3202: - [~apovzner] Moved test description to Compatibi

[jira] [Updated] (KAFKA-3188) Add system test for KIP-31 and KIP-32 - Compatibility Test

2016-03-10 Thread Eno Thereska (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-3188: Description: The integration test should test the compatibility between 0.10.0 broker with clients

[jira] [Updated] (KAFKA-3202) Add system test for KIP-31 and KIP-32 - Change message format version on the fly

2016-03-10 Thread Eno Thereska (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-3202: Description: The system test should cover the case that message format changes are made when client

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

2016-03-10 Thread Apache Jenkins Server
See

Build failed in Jenkins: kafka_0.9.0_jdk7 #128

2016-03-10 Thread Apache Jenkins Server
See Changes: [cshapi] MINOR: Add header and footer to protocol docs -- [...truncated 3018 lines...] kafka.message.MessageTest > testChecksum PASSED kafka.message.MessageTest > testIsHashable PAS

[jira] [Commented] (KAFKA-3367) Delete topic dont delete the complete log from kafka

2016-03-10 Thread Mayuresh Gharat (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189933#comment-15189933 ] Mayuresh Gharat commented on KAFKA-3367: Is automatic topic creation turned ON in

[jira] [Commented] (KAFKA-3202) Add system test for KIP-31 and KIP-32 - Change message format version on the fly

2016-03-10 Thread Anna Povzner (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189917#comment-15189917 ] Anna Povzner commented on KAFKA-3202: - [~enothereska] I think you meant to post the te

[jira] [Commented] (KAFKA-3367) Delete topic dont delete the complete log from kafka

2016-03-10 Thread Akshath Patkar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189874#comment-15189874 ] Akshath Patkar commented on KAFKA-3367: --- [~mgharat] thanks. i am using confluent pac

[GitHub] kafka pull request: MINOR: Add unit test for internal topics

2016-03-10 Thread guozhangwang
GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/1047 MINOR: Add unit test for internal topics You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka KInternal Alternatively you ca

[GitHub] kafka pull request: MINOR: Increased default EC2 instance size

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

[GitHub] kafka pull request: MINOR: Increased default EC2 instance size

2016-03-10 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/1046 MINOR: Increased default EC2 instance size AWS instance size increased to m3.xlarge to allow all system tests to pass. @ijuma @ewencp have a look please. You can merge this pull request into a

[GitHub] kafka pull request: MINOR: Increase AWS instance size

2016-03-10 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/1045 --- 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-3296) All consumer reads hang indefinately

2016-03-10 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189851#comment-15189851 ] Jason Gustafson commented on KAFKA-3296: [~thecoop1984] Sorry, haven't had any tim

[GitHub] kafka pull request: MINOR: Increase AWS instance size

2016-03-10 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/1045 MINOR: Increase AWS instance size AWS instance size increased to m3.xlarge to allow all system tests to pass. You can merge this pull request into a Git repository by running: $ git pull ht

[jira] [Updated] (KAFKA-3378) Client blocks forever if SocketChannel connects instantly

2016-03-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3378: --- Priority: Critical (was: Major) > Client blocks forever if SocketChannel connects instantly > ---

[jira] [Updated] (KAFKA-3378) Client blocks forever if SocketChannel connects instantly

2016-03-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3378: --- Fix Version/s: 0.10.0.0 > Client blocks forever if SocketChannel connects instantly >

[jira] [Commented] (KAFKA-3378) Client blocks forever if SocketChannel connects instantly

2016-03-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189815#comment-15189815 ] ASF GitHub Bot commented on KAFKA-3378: --- GitHub user llowrey opened a pull request:

[GitHub] kafka pull request: KAFKA-3378 Fix for instantly connecting Socket...

2016-03-10 Thread llowrey
GitHub user llowrey opened a pull request: https://github.com/apache/kafka/pull/1044 KAFKA-3378 Fix for instantly connecting SocketChannels. Added OP_WRITE interestOp when channel connects instantly (socketChannel.connect(address) returns true... even in non-blocking mode). This al

[jira] [Resolved] (KAFKA-3318) Improve consumer rebalance error messaging

2016-03-10 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-3318. - Resolution: Fixed Fix Version/s: 0.10.0.0 Issue resolved by pull request 1036 [https://gith

[jira] [Commented] (KAFKA-3318) Improve consumer rebalance error messaging

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

[GitHub] kafka pull request: KAFKA-3318: clean up consumer logging and erro...

2016-03-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1036 --- 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] [Created] (KAFKA-3378) Client blocks forever if SocketChannel connects instantly

2016-03-10 Thread Larkin Lowrey (JIRA)
Larkin Lowrey created KAFKA-3378: Summary: Client blocks forever if SocketChannel connects instantly Key: KAFKA-3378 URL: https://issues.apache.org/jira/browse/KAFKA-3378 Project: Kafka Issue

[GitHub] kafka pull request: Minor: Fix system test broken by change of con...

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

[GitHub] kafka-site pull request: Add protocol guide

2016-03-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka-site/pull/9 --- 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 en

[jira] [Commented] (KAFKA-3345) ProducerResponse could gracefully handle no throttle time provided

2016-03-10 Thread Bryan Baugher (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189757#comment-15189757 ] Bryan Baugher commented on KAFKA-3345: -- Looks like this is no longer as easy with the

Re: [DISCUSS] KIP-35 - Retrieve protocol version

2016-03-10 Thread Ashish Singh
@Magnus, Does the latest suggestion sound OK to you. I am planning to update PR based on latest suggestion. On Mon, Mar 7, 2016 at 10:58 AM, Ashish Singh wrote: > > > On Fri, Mar 4, 2016 at 5:46 PM, Jay Kreps wrote: > >> Hey Ashish, >> >> Both good points. >> >> I think the issue with the gene

[jira] [Commented] (KAFKA-3361) Initial protocol documentation page and generation

2016-03-10 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189720#comment-15189720 ] Gwen Shapira commented on KAFKA-3361: - merged. Sorry for accidentally breaking the bui

[GitHub] kafka pull request: MINOR: Add header and footer to protocol docs

2016-03-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1043 --- 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-3202) Add system test for KIP-31 and KIP-32 - Change message format version on the fly

2016-03-10 Thread Eno Thereska (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189692#comment-15189692 ] Eno Thereska commented on KAFKA-3202: - [~becket_qin]: I've updated the JIRA descriptio

Re: [GitHub] kafka pull request: Parallel log-recovery of un-flushed segments o...

2016-03-10 Thread Achanta Vamsi Subhash
Hi, I would like to make this into 0.0.10.0 so can someone look into this and review? On Wed, Mar 9, 2016 at 10:29 PM, Achanta Vamsi Subhash < achanta.va...@flipkart.com> wrote: > Hi all, > > https://github.com/apache/kafka/pull/1035 > This pull request will make the log-segment load parallel wit

[jira] [Updated] (KAFKA-3202) Add system test for KIP-31 and KIP-32 - Change message format version on the fly

2016-03-10 Thread Eno Thereska (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-3202: Description: The system test should cover the case that message format changes are made when client

[jira] [Commented] (KAFKA-3367) Delete topic dont delete the complete log from kafka

2016-03-10 Thread Mayuresh Gharat (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189676#comment-15189676 ] Mayuresh Gharat commented on KAFKA-3367: It takes time to delete the logs, dependi

[jira] [Commented] (KAFKA-3361) Initial protocol documentation page and generation

2016-03-10 Thread Grant Henke (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189661#comment-15189661 ] Grant Henke commented on KAFKA-3361: [~becket_qin] I have that included in this PR: h

[GitHub] kafka-site pull request: Add protocol guide

2016-03-10 Thread granthenke
Github user granthenke commented on the pull request: https://github.com/apache/kafka-site/pull/9#issuecomment-194980209 This was briefly tested locally with an Apache web server. It includes https://github.com/apache/kafka/pull/1043 --- If your project is set up for it, you can repl

[GitHub] kafka-site pull request: Add protocol guide

2016-03-10 Thread granthenke
Github user granthenke commented on the pull request: https://github.com/apache/kafka-site/pull/9#issuecomment-194980267 cc @gwenshap --- 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 fea

[jira] [Commented] (KAFKA-3361) Initial protocol documentation page and generation

2016-03-10 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189646#comment-15189646 ] Jiangjie Qin commented on KAFKA-3361: - [~gwenshap] [~granthenke] It seems docs/protoco

[GitHub] kafka-site pull request: Add protocol guide

2016-03-10 Thread granthenke
GitHub user granthenke opened a pull request: https://github.com/apache/kafka-site/pull/9 Add protocol guide You can merge this pull request into a Git repository by running: $ git pull https://github.com/granthenke/kafka-site protocol Alternatively you can review and apply t

[GitHub] kafka pull request: MINOR: Add header and footer to protocol docs

2016-03-10 Thread granthenke
GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/1043 MINOR: Add header and footer to protocol docs Because protocol.html is going to be in its own page it needs the header and footer included. You can merge this pull request into a Git repository

[jira] [Resolved] (KAFKA-3118) Fail test at: ProducerBounceTest. testBrokerFailure

2016-03-10 Thread aarti gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aarti gupta resolved KAFKA-3118. Resolution: Cannot Reproduce > Fail test at: ProducerBounceTest. testBrokerFailure > --

Re: [VOTE] Release plan - Kafka 0.10.0

2016-03-10 Thread Gwen Shapira
Thanks all the Kafka contributors for voting! The vote passes with 6 binding +1, 5 non-binding +1 and no -1. We are now 11 days before the first planned release candidate. We have 12 open blockers, 17 open critical issues and a grand total of 108 issues for the release. I added a widget showing

[jira] [Assigned] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

2016-03-10 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned KAFKA-3373: --- Assignee: Jiangjie Qin > Add `log` prefix to KIP-31/32 configs >

Re: [jira] [Created] (KAFKA-3377) add REST interface to JMX

2016-03-10 Thread Gerard Klijs
I would like to know why you want/need it to be integrated into Kafka? For our current project we tried out zabbix, https://www.zabbix.com/documentation/3.0/manual/config/items/itemtypes/jmx_monitoring, it takes some configuration, but then you can fetch all the jmx you want and put them into graph

[jira] [Created] (KAFKA-3377) add REST interface to JMX

2016-03-10 Thread Christian Posta (JIRA)
Christian Posta created KAFKA-3377: -- Summary: add REST interface to JMX Key: KAFKA-3377 URL: https://issues.apache.org/jira/browse/KAFKA-3377 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-3376) have sensible defaults for the command-line tools to facilitate local development

2016-03-10 Thread Christian Posta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christian Posta updated KAFKA-3376: --- Component/s: packaging admin > have sensible defaults for the command-line to

[jira] [Created] (KAFKA-3376) have sensible defaults for the command-line tools to facilitate local development

2016-03-10 Thread Christian Posta (JIRA)
Christian Posta created KAFKA-3376: -- Summary: have sensible defaults for the command-line tools to facilitate local development Key: KAFKA-3376 URL: https://issues.apache.org/jira/browse/KAFKA-3376 P

[jira] [Updated] (KAFKA-3376) have sensible defaults for the command-line tools to facilitate local development

2016-03-10 Thread Christian Posta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christian Posta updated KAFKA-3376: --- Affects Version/s: 0.9.0.1 > have sensible defaults for the command-line tools to facilitate l

[jira] [Updated] (KAFKA-3359) Parallel log-recovery of un-flushed segments on startup

2016-03-10 Thread Vamsi Subhash Achanta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vamsi Subhash Achanta updated KAFKA-3359: - Reviewer: Grant Henke Fix Version/s: 0.10.0.0 Status: Patch Ava

[jira] [Updated] (KAFKA-3375) Suppress and fix compiler warnings where reasonable and tweak compiler settings

2016-03-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3375: --- Summary: Suppress and fix compiler warnings where reasonable and tweak compiler settings (was: Suppre

[jira] [Updated] (KAFKA-3375) Suppress deprecated warnings where reasonable and tweak compiler settings

2016-03-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3375: --- Status: Patch Available (was: Open) > Suppress deprecated warnings where reasonable and tweak compile

[jira] [Commented] (KAFKA-3375) Suppress deprecated warnings where reasonable and tweak compiler settings

2016-03-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189199#comment-15189199 ] ASF GitHub Bot commented on KAFKA-3375: --- GitHub user ijuma opened a pull request:

[GitHub] kafka pull request: KAFKA-3375; Suppress deprecated warnings where...

2016-03-10 Thread ijuma
GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/1042 KAFKA-3375; Suppress deprecated warnings where reasonable and tweak compiler settings * Fix and suppress number of unchecked warnings (except for Kafka Streams) * Add `@SafeVarargs` annotation to

[jira] [Created] (KAFKA-3375) Suppress deprecated warnings where reasonable and tweak compiler settings

2016-03-10 Thread Ismael Juma (JIRA)
Ismael Juma created KAFKA-3375: -- Summary: Suppress deprecated warnings where reasonable and tweak compiler settings Key: KAFKA-3375 URL: https://issues.apache.org/jira/browse/KAFKA-3375 Project: Kafka

Jenkins build is back to normal : kafka-trunk-jdk8 #434

2016-03-10 Thread Apache Jenkins Server
See

[GitHub] kafka pull request: Kafka 3173

2016-03-10 Thread fpj
GitHub user fpj opened a pull request: https://github.com/apache/kafka/pull/1041 Kafka 3173 You can merge this pull request into a Git repository by running: $ git pull https://github.com/fpj/kafka KAFKA-3173 Alternatively you can review and apply these changes as the patch a

[jira] [Updated] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

2016-03-10 Thread Flavio Junqueira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-3173: Attachment: KAFKA-3173-race-repro.patch > Error while moving some partitions to OnlinePartit

[jira] [Updated] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

2016-03-10 Thread Flavio Junqueira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-3173: Attachment: (was: KAFKA-3173-race-repo.patch) > Error while moving some partitions to On

[jira] [Updated] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

2016-03-10 Thread Flavio Junqueira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-3173: Attachment: KAFKA-3173-race-repo.patch > Error while moving some partitions to OnlinePartiti

[jira] [Commented] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

2016-03-10 Thread Flavio Junqueira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189024#comment-15189024 ] Flavio Junqueira commented on KAFKA-3173: - I have investigated the two races furth

[jira] [Created] (KAFKA-3374) Failure in security rolling upgrade phase 2 system test

2016-03-10 Thread Ismael Juma (JIRA)
Ismael Juma created KAFKA-3374: -- Summary: Failure in security rolling upgrade phase 2 system test Key: KAFKA-3374 URL: https://issues.apache.org/jira/browse/KAFKA-3374 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

2016-03-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3373: --- Issue Type: Bug (was: Test) > Add `log` prefix to KIP-31/32 configs > ---

[jira] [Commented] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

2016-03-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15188982#comment-15188982 ] Ismael Juma commented on KAFKA-3373: cc [~becket_qin] [~junrao] > Add `log` prefix to

[jira] [Created] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

2016-03-10 Thread Ismael Juma (JIRA)
Ismael Juma created KAFKA-3373: -- Summary: Add `log` prefix to KIP-31/32 configs Key: KAFKA-3373 URL: https://issues.apache.org/jira/browse/KAFKA-3373 Project: Kafka Issue Type: Test

[jira] [Updated] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

2016-03-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3373: --- Priority: Blocker (was: Major) > Add `log` prefix to KIP-31/32 configs >

[jira] [Commented] (KAFKA-3248) AdminClient Blocks Forever in send Method

2016-03-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15188979#comment-15188979 ] Ismael Juma commented on KAFKA-3248: I bumped the priority as blocking forever is not

[jira] [Updated] (KAFKA-3248) AdminClient Blocks Forever in send Method

2016-03-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3248: --- Priority: Critical (was: Minor) > AdminClient Blocks Forever in send Method > ---

[jira] [Updated] (KAFKA-3248) AdminClient Blocks Forever in send Method

2016-03-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3248: --- Fix Version/s: 0.10.0.0 > AdminClient Blocks Forever in send Method >

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

2016-03-10 Thread Apache Jenkins Server
See Changes: [me] KAFKA-3344: Remove previous system test's leftover test-log4j.properties -- [...truncated 110 lines...] :kafka-trunk-jdk7:clients:classes UP-TO-DATE :kafka-trunk-jdk7:clients:d

[jira] [Created] (KAFKA-3372) Trailing space in Kafka ConsumerConfig

2016-03-10 Thread Kundan (JIRA)
Kundan created KAFKA-3372: - Summary: Trailing space in Kafka ConsumerConfig Key: KAFKA-3372 URL: https://issues.apache.org/jira/browse/KAFKA-3372 Project: Kafka Issue Type: Bug Components:

[jira] [Updated] (KAFKA-3371) ClientCompatibilityTest system test failing since KIP-31/KIP-32 was merged

2016-03-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3371: --- Summary: ClientCompatibilityTest system test failing since KIP-31/KIP-32 was merged (was: ClientCompa

[jira] [Created] (KAFKA-3371) ClientCompatibilityTest system test failing since KIP-31/KIP-32

2016-03-10 Thread Ismael Juma (JIRA)
Ismael Juma created KAFKA-3371: -- Summary: ClientCompatibilityTest system test failing since KIP-31/KIP-32 Key: KAFKA-3371 URL: https://issues.apache.org/jira/browse/KAFKA-3371 Project: Kafka Is

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

2016-03-10 Thread Apache Jenkins Server
See Changes: [cshapi] MINOR: KAFKA-3361 follow up -- [...truncated 1510 lines...] kafka.api.AdminClientTest > testListGroups PASSED kafka.api.AdminClientTest > testDescribeConsumerGroupForNonEx

[GitHub] kafka pull request: MINOR: update compression design doc to includ...

2016-03-10 Thread omkreddy
GitHub user omkreddy opened a pull request: https://github.com/apache/kafka/pull/1040 MINOR: update compression design doc to include lz4 protocol You can merge this pull request into a Git repository by running: $ git pull https://github.com/omkreddy/kafka MINOR-DOC Alternat

Re: [DISCUSS] KIP-43: Kafka SASL enhancements

2016-03-10 Thread Rajini Sivaram
Gwen, Just to be clear, the alternative would be: *jaas.conf:* GssapiKafkaServer { com.ibm.security.auth.module.Krb5LoginModule required credsType=both useKeytab="file:/kafka/key.tab" principal="kafka/localh...@example.com "; }; SmartcardKafkaServer { example.Smartcard