Re: 0.9.0.1 RC1

2016-02-15 Thread Neha Narkhede
+1 (binding). Verified source and binary artifacts, ran ./gradlew testAll, quick start on source artifact and Scala 2.11 binary artifact. On Mon, Feb 15, 2016 at 7:43 PM, Ewen Cheslack-Postava wrote: > Yeah, I saw > > kafka.network.SocketServerTest > tooBigRequestIsRejected FAILED > java.ne

[jira] [Commented] (KAFKA-3093) Keep track of connector and task status info, expose it via the REST API

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

[GitHub] kafka pull request: KAFKA-3093 [WIP]: Add status tracking API

2016-02-15 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/920 KAFKA-3093 [WIP]: Add status tracking API You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-3093 Alternatively you can rev

[GitHub] kafka pull request: KAFKA-3093 [WIP]: Add Connect status tracking ...

2016-02-15 Thread hachikuji
Github user hachikuji closed the pull request at: https://github.com/apache/kafka/pull/919 --- 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-3093) Keep track of connector and task status info, expose it via the REST API

2016-02-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15148093#comment-15148093 ] ASF GitHub Bot commented on KAFKA-3093: --- Github user hachikuji closed the pull reque

[GitHub] kafka pull request: KAFKA-3214 [WIP]: Add Connect status tracking ...

2016-02-15 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/919 KAFKA-3214 [WIP]: Add Connect status tracking API You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-3214 Alternatively you

[jira] [Commented] (KAFKA-3214) Add consumer system tests for compressed topics

2016-02-15 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15148085#comment-15148085 ] Jason Gustafson commented on KAFKA-3214: Disregard PR. Put the wrong JIRA by mista

[jira] [Commented] (KAFKA-3214) Add consumer system tests for compressed topics

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

Re: 0.9.0.1 RC1

2016-02-15 Thread Ewen Cheslack-Postava
Yeah, I saw kafka.network.SocketServerTest > tooBigRequestIsRejected FAILED java.net.SocketException: Broken pipe at java.net.SocketOutputStream.socketWrite0(Native Method) at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:113) at java.net.SocketOutputS

Re: 0.9.0.1 RC1

2016-02-15 Thread Ismael Juma
+1 (non-binding). Verified source and binary artifacts, ran ./gradlew testAll with JDK 7u80, quick start on source artifact and Scala 2.11 binary artifact. Ismael On Fri, Feb 12, 2016 at 2:55 AM, Jun Rao wrote: > This is the first candidate for release of Apache Kafka 0.9.0.1. This a bug > fix

[jira] [Commented] (KAFKA-3145) CPU Usage Spike to 100% when network connection is to error port

2016-02-15 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147971#comment-15147971 ] Dong Lin commented on KAFKA-3145: - [~zhiwei] Can you want to try to reproduce it using tru

[jira] [Commented] (KAFKA-3145) CPU Usage Spike to 100% when network connection is to error port

2016-02-15 Thread zhiwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147953#comment-15147953 ] zhiwei commented on KAFKA-3145: --- [~lindong] Use 0.8.2.1 newproducer client API, and config

[jira] [Commented] (KAFKA-3145) CPU Usage Spike to 100% when network connection is to error port

2016-02-15 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147932#comment-15147932 ] Dong Lin commented on KAFKA-3145: - [~zhiwei], yeah I understand that CPU usage depends the

[jira] [Commented] (KAFKA-3145) CPU Usage Spike to 100% when network connection is to error port

2016-02-15 Thread zhiwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147922#comment-15147922 ] zhiwei commented on KAFKA-3145: --- [~lindong] Machine performance relatively poor , cpu usa

Re: 0.9.0.1 RC1

2016-02-15 Thread Flavio Junqueira
I'm also getting test failures. Here are tests that failed for me and the jiras I could find reporting the corresponding issue: org.apache.kafka.common.network.SslTransportLayerTest > testInvalidEndpointIdentification - KAFKA-2850 kafka.api.QuotasTest > testThrottledProducerConsumer - KAFKA-2444

[jira] [Commented] (KAFKA-3145) CPU Usage Spike to 100% when network connection is to error port

2016-02-15 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147899#comment-15147899 ] Dong Lin commented on KAFKA-3145: - [~zhiwei], I am not able to reproduce the problem. I st

[jira] [Commented] (KAFKA-3007) Implement max.poll.records for new consumer (KIP-41)

2016-02-15 Thread Erik Pettersson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147845#comment-15147845 ] Erik Pettersson commented on KAFKA-3007: No problem! Was just thinking about if I

[GitHub] kafka pull request: KAFKA-3133: Add putIfAbsent function to KeyVal...

2016-02-15 Thread kichristensen
GitHub user kichristensen reopened a pull request: https://github.com/apache/kafka/pull/912 KAFKA-3133: Add putIfAbsent function to KeyValueStore @guozhangwang You can merge this pull request into a Git repository by running: $ git pull https://github.com/kichristensen/kafka KA

[jira] [Commented] (KAFKA-3133) Add putIfAbsent function to KeyValueStore

2016-02-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147801#comment-15147801 ] ASF GitHub Bot commented on KAFKA-3133: --- GitHub user kichristensen reopened a pull r

[jira] [Commented] (KAFKA-3133) Add putIfAbsent function to KeyValueStore

2016-02-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147800#comment-15147800 ] ASF GitHub Bot commented on KAFKA-3133: --- Github user kichristensen closed the pull r

[GitHub] kafka pull request: KAFKA-3133: Add putIfAbsent function to KeyVal...

2016-02-15 Thread kichristensen
Github user kichristensen closed the pull request at: https://github.com/apache/kafka/pull/912 --- 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 i

[GitHub] kafka pull request: Add expected Error Codes to ProduceResponse do...

2016-02-15 Thread dpkp
GitHub user dpkp opened a pull request: https://github.com/apache/kafka/pull/918 Add expected Error Codes to ProduceResponse documentation This is a documentation-only patch discussed on the mailing list. The intent is to have these changes propagated to the protocol wiki (https://

[GitHub] kafka pull request: Properly quote $JAVA in order to avoid failure...

2016-02-15 Thread pbaille
GitHub user pbaille opened a pull request: https://github.com/apache/kafka/pull/917 Properly quote $JAVA in order to avoid failure due to space char in PATH You can merge this pull request into a Git repository by running: $ git pull https://github.com/pbaille/kafka trunk Alt

[GitHub] kafka pull request: Properly quote $JAVA in bin/kafka-run-class.sh...

2016-02-15 Thread pbaille
Github user pbaille closed the pull request at: https://github.com/apache/kafka/pull/916 --- 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: Properly quote $JAVA in bin/kafka-run-class.sh...

2016-02-15 Thread pbaille
GitHub user pbaille opened a pull request: https://github.com/apache/kafka/pull/916 Properly quote $JAVA in bin/kafka-run-class.sh in order to avoid failure due to space char in PATH You can merge this pull request into a Git repository by running: $ git pull https://github.c

[jira] [Commented] (KAFKA-3007) Implement max.poll.records for new consumer (KIP-41)

2016-02-15 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147713#comment-15147713 ] Jason Gustafson commented on KAFKA-3007: [~eripe...@gmail.com] Apologies for the d

[jira] [Commented] (KAFKA-3007) Implement max.poll.records for new consumer (KIP-41)

2016-02-15 Thread Erik Pettersson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147662#comment-15147662 ] Erik Pettersson commented on KAFKA-3007: Has any work been done to this issue? >

[jira] [Commented] (KAFKA-3093) Keep track of connector and task status info, expose it via the REST API

2016-02-15 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147590#comment-15147590 ] Jason Gustafson commented on KAFKA-3093: [~jinxing6...@126.com] I should have a pa

[jira] [Comment Edited] (KAFKA-3172) Consumer threads stay in 'Watiting' status and are blocked at consumer poll method

2016-02-15 Thread Dany Benjamin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147563#comment-15147563 ] Dany Benjamin edited comment on KAFKA-3172 at 2/15/16 4:44 PM: -

[jira] [Commented] (KAFKA-3218) Kafka-0.9.0.0 does not work as OSGi module

2016-02-15 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147565#comment-15147565 ] Rajini Sivaram commented on KAFKA-3218: --- [~lowerobert] [~joconnor] Have you tried wi

[jira] [Commented] (KAFKA-3172) Consumer threads stay in 'Watiting' status and are blocked at consumer poll method

2016-02-15 Thread Dany Benjamin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147563#comment-15147563 ] Dany Benjamin commented on KAFKA-3172: -- Yes. This is the jstack dump I am getting. I

[jira] [Comment Edited] (KAFKA-3093) Keep track of connector and task status info, expose it via the REST API

2016-02-15 Thread jin xing (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147559#comment-15147559 ] jin xing edited comment on KAFKA-3093 at 2/15/16 4:43 PM: -- [~hach

[jira] [Commented] (KAFKA-3093) Keep track of connector and task status info, expose it via the REST API

2016-02-15 Thread jin xing (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147559#comment-15147559 ] jin xing commented on KAFKA-3093: - [~hachikuji] It's great if you can work on this; I like

[jira] [Updated] (KAFKA-3224) Add timestamp-based log deletion policy

2016-02-15 Thread Bill Warshaw (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Warshaw updated KAFKA-3224: Description: One of Kafka's officially-described use cases is a distributed commit log (http://kafk

[jira] [Commented] (KAFKA-3218) Kafka-0.9.0.0 does not work as OSGi module

2016-02-15 Thread Joe O'Connor (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147536#comment-15147536 ] Joe O'Connor commented on KAFKA-3218: - The problem with the workaround seems to be tha

Re: New Consumer Poll bug?

2016-02-15 Thread Phil Steitz
On 2/13/16 6:16 AM, Ismael Juma wrote: > Hi Damian, > > KAFKA-2978, which would cause consumption to stop would happen after a > consumer group rebalance. Was this the case for you? > > It would be great if you could upgrade the client to 0.9.0.1 RC1 in order > to check if the problem still happens

Re: 0.9.0.1 RC1

2016-02-15 Thread Phil Steitz
I get the following test failures on both OSX (10.11.3) and Ubuntu (14.04), JDK 1.7 and 1.8. KafkaConsumerTest. testConstructorClose KafkaProducerTest. testConstructorFailureCloseResource SelectorTest. testNoRouteToHost SslSelectorTest. testNoRouteToHost All seem to be expecting exceptions that a

[jira] [Comment Edited] (KAFKA-3218) Kafka-0.9.0.0 does not work as OSGi module

2016-02-15 Thread Robert Lowe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147425#comment-15147425 ] Robert Lowe edited comment on KAFKA-3218 at 2/15/16 2:45 PM: -

[jira] [Commented] (KAFKA-3218) Kafka-0.9.0.0 does not work as OSGi module

2016-02-15 Thread Robert Lowe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147425#comment-15147425 ] Robert Lowe commented on KAFKA-3218: Suggested fix throws error on bundle:start {code}

[jira] [Commented] (KAFKA-3135) Unexpected delay before fetch response transmission

2016-02-15 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147379#comment-15147379 ] Ismael Juma commented on KAFKA-3135: [~hachikuji], do you know why the receive buffer

[GitHub] kafka pull request: MINOR: Doc of topic-level configuration was ma...

2016-02-15 Thread sasakitoa
GitHub user sasakitoa opened a pull request: https://github.com/apache/kafka/pull/915 MINOR: Doc of topic-level configuration was made understandable. Some configuration of Broker topic-level conf should be specified Int or Long. Currently docs will mislead to allow to use unit

[jira] [Commented] (KAFKA-3129) Console Producer/Consumer Issue

2016-02-15 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147050#comment-15147050 ] Rajini Sivaram commented on KAFKA-3129: --- At the moment {{PlaintextTransportLayer.clo