[jira] [Commented] (KAFKA-2370) Add pause/unpause connector support

2015-11-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14989081#comment-14989081 ] ASF GitHub Bot commented on KAFKA-2370: --- GitHub user guozhangwang opened a pull requ

[GitHub] kafka pull request: KAFKA-2370: use thread-id as metrics tags

2015-11-03 Thread guozhangwang
GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/416 KAFKA-2370: use thread-id as metrics tags You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K2730 Alternatively you can re

[jira] [Commented] (KAFKA-2730) partition-reassignment tool stops working due to error in registerMetric

2015-11-03 Thread Hannu Valtonen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14989074#comment-14989074 ] Hannu Valtonen commented on KAFKA-2730: --- No security features were in use in this pa

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

2015-11-03 Thread Grant Henke (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14989036#comment-14989036 ] Grant Henke commented on KAFKA-2702: [~gwenshap] There was no default for group.id in

Re: kafka_2.9.2-0.8.2.0 - Topic marked for deletion

2015-11-03 Thread Grant Henke
Hi Avinash, This is working as expected. Since delete topics is not enabled, they get marked for deletion, but never get deleted. Once you enable topic deletion (delete.topic.enable=true) the topics marked get delete. Once the topic is marked for deletion messages will still be available. It is w

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

2015-11-03 Thread Apache Jenkins Server
See Changes: [junrao] KAFKA-2644; Run relevant ducktape tests with SASL_PLAINTEXT and SASL_SSL -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H

Re: Authorization Engine For Kafka Related to KPI-11

2015-11-03 Thread Bhavesh Mistry
+ Kafka Dev team to see if Kafka Dev team know or recommend any Auth engine for Producers/Consumers. Thanks, Bhavesh Please pardon me, I accidentally send previous blank email. On Tue, Nov 3, 2015 at 9:52 PM, Bhavesh Mistry wrote: > On Sun, Nov 1, 2015 at 11:15 PM, Bhavesh Mistry > wrote: >>

Re: Authorization Engine For Kafka Related to KPI-11

2015-11-03 Thread Bhavesh Mistry
On Sun, Nov 1, 2015 at 11:15 PM, Bhavesh Mistry wrote: > HI All, > > Have any one used Apache Ranger as Authorization Engine for Kafka Topic > creation, consumption (read) and write operation on a topic. I am looking > at having audit log and regulating consumption/ write to particular topic > (

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

2015-11-03 Thread Apache Jenkins Server
See Changes: [junrao] KAFKA-2644; Run relevant ducktape tests with SASL_PLAINTEXT and SASL_SSL -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on

kafka_2.9.2-0.8.2.0 - Topic marked for deletion

2015-11-03 Thread Kumar, Avinash
Hi, I am trying to delete the kafka topic, verison I am using is 2.9.2-0.8.2. I am using dockerized kafka to delete the topic already created and didn’t set the “delete.topic.enable=true”. When I am listing the topics, it is giving as “ marked for deletion”. Is this a bug? However when I am s

[jira] [Commented] (KAFKA-2644) Run relevant ducktape tests with SASL_PLAINTEXT and SASL_SSL

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

[jira] [Updated] (KAFKA-2644) Run relevant ducktape tests with SASL_PLAINTEXT and SASL_SSL

2015-11-03 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2644: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request 358 [https:/

[GitHub] kafka pull request: KAFKA-2644: Run relevant ducktape tests with S...

2015-11-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/358 --- 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-2738) Can't set SSL as inter-broker-protocol by rolling restart of brokers

2015-11-03 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2738: --- Assignee: Ben Stopford Priority: Blocker (was: Major) Fix Version/s: 0.9.0.0 > Can't set SS

[jira] [Resolved] (KAFKA-2046) Delete topic still doesn't work

2015-11-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2046. - Resolution: Cannot Reproduce > Delete topic still doesn't work > --- >

[jira] [Commented] (KAFKA-2738) Can't set SSL as inter-broker-protocol by rolling restart of brokers

2015-11-03 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14988785#comment-14988785 ] Jun Rao commented on KAFKA-2738: Good find. In ReplicaManager.makeFollowers(), we have the

[jira] [Commented] (KAFKA-2735) BrokerEndPoint should support non-lowercase hostnames

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

[jira] [Updated] (KAFKA-2735) BrokerEndPoint should support uppercase hostnames

2015-11-03 Thread Jeff Holoman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated KAFKA-2735: Summary: BrokerEndPoint should support uppercase hostnames (was: BrokerEndPoint should support non-

[GitHub] kafka pull request: KAFKA-2735 BrokerEndPoint should support upper...

2015-11-03 Thread jholoman
GitHub user jholoman opened a pull request: https://github.com/apache/kafka/pull/415 KAFKA-2735 BrokerEndPoint should support uppercase hostnames Added support for uppercase hostnames in BrokerEndPoint. Added unit test to cover this scenario. You can merge this pull request into

[jira] [Updated] (KAFKA-2379) Add Copycat documentation

2015-11-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2379: Priority: Blocker (was: Major) > Add Copycat documentation > - > >

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

2015-11-03 Thread Stevo Slavic (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stevo Slavic updated KAFKA-2255: Fix Version/s: 0.9.0.0 > Missing documentation for max.in.flight.requests.per.connection > -

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

2015-11-03 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14988635#comment-14988635 ] Jason Gustafson commented on KAFKA-2702: I think it's only required if the user is

[jira] [Created] (KAFKA-2739) Bug in ZKClient may cause failure to start brokers

2015-11-03 Thread Gwen Shapira (JIRA)
Gwen Shapira created KAFKA-2739: --- Summary: Bug in ZKClient may cause failure to start brokers Key: KAFKA-2739 URL: https://issues.apache.org/jira/browse/KAFKA-2739 Project: Kafka Issue Type: Bu

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

2015-11-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14988628#comment-14988628 ] Gwen Shapira commented on KAFKA-2702: - Not 100% related to this patch, but I thought g

[jira] [Comment Edited] (KAFKA-2730) partition-reassignment tool stops working due to error in registerMetric

2015-11-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14988441#comment-14988441 ] Guozhang Wang edited comment on KAFKA-2730 at 11/4/15 12:54 AM:

[jira] [Updated] (KAFKA-2737) Integration tests for round-robin assignment

2015-11-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2737: - Reviewer: Guozhang Wang > Integration tests for round-robin assignment > -

[jira] [Updated] (KAFKA-2738) Can't set SSL as inter-broker-protocol by rolling restart of brokers

2015-11-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2738: Description: Scenario (as carefully documented by [~benstopford]: 1. Start 2 or more brokers with l

[jira] [Created] (KAFKA-2738) Can't set SSL as inter-broker-protocol by rolling restart of brokers

2015-11-03 Thread Gwen Shapira (JIRA)
Gwen Shapira created KAFKA-2738: --- Summary: Can't set SSL as inter-broker-protocol by rolling restart of brokers Key: KAFKA-2738 URL: https://issues.apache.org/jira/browse/KAFKA-2738 Project: Kafka

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

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

[jira] [Commented] (KAFKA-2737) Integration tests for round-robin assignment

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

[GitHub] kafka pull request: KAFKA-2697: client-side support for leave grou...

2015-11-03 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/414 KAFKA-2697: client-side support for leave group You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-2697 Alternatively you c

[GitHub] kafka pull request: KAFKA-2737: Added single- and multi-consumer i...

2015-11-03 Thread apovzner
GitHub user apovzner opened a pull request: https://github.com/apache/kafka/pull/413 KAFKA-2737: Added single- and multi-consumer integration tests for round-robin assignment Two tests: 1. One consumer subscribes to 2 topics, each with 2 partitions; includes adding and removing

[jira] [Created] (KAFKA-2737) Integration tests for round-robin assignment

2015-11-03 Thread Anna Povzner (JIRA)
Anna Povzner created KAFKA-2737: --- Summary: Integration tests for round-robin assignment Key: KAFKA-2737 URL: https://issues.apache.org/jira/browse/KAFKA-2737 Project: Kafka Issue Type: Test

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

2015-11-03 Thread Apache Jenkins Server
See Changes: [wangguoz] KAFKA-2441: SSL/TLS in official docs [wangguoz] KAFKA-2687: Add support for ListGroups and DescribeGroup APIs -- [...truncated 3972 lines...] kafka.log.BrokerCompressionT

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

2015-11-03 Thread Grant Henke (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14988504#comment-14988504 ] Grant Henke edited comment on KAFKA-2702 at 11/3/15 11:54 PM: --

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

2015-11-03 Thread Grant Henke (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14988504#comment-14988504 ] Grant Henke commented on KAFKA-2702: Thanks for all the input [~jkreps][~gwenshap][~ab

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

2015-11-03 Thread Grant Henke (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-2702: --- Attachment: ConsumerConfig-After-v2.html > ConfigDef toHtmlTable() sorts in a way that is a bit confus

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

2015-11-03 Thread Apache Jenkins Server
See Changes: [wangguoz] KAFKA-2687: Add support for ListGroups and DescribeGroup APIs -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (Ubunt

[jira] [Created] (KAFKA-2736) ZkClient doesn't handle SaslAuthenticated

2015-11-03 Thread Flavio Junqueira (JIRA)
Flavio Junqueira created KAFKA-2736: --- Summary: ZkClient doesn't handle SaslAuthenticated Key: KAFKA-2736 URL: https://issues.apache.org/jira/browse/KAFKA-2736 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-2730) partition-reassignment tool stops working due to error in registerMetric

2015-11-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14988441#comment-14988441 ] Guozhang Wang commented on KAFKA-2730: -- Thanks [~Ormod], did you use enable any secur

[jira] [Created] (KAFKA-2735) BrokerEndPoint should support non-lowercase hostnames

2015-11-03 Thread Jeff Holoman (JIRA)
Jeff Holoman created KAFKA-2735: --- Summary: BrokerEndPoint should support non-lowercase hostnames Key: KAFKA-2735 URL: https://issues.apache.org/jira/browse/KAFKA-2735 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-2734) kafka-console-consumer throws NoSuchElementException on not specifying topic

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

[GitHub] kafka pull request: KAFKA-2734: kafka-console-consumer throws NoSu...

2015-11-03 Thread SinghAsDev
GitHub user SinghAsDev opened a pull request: https://github.com/apache/kafka/pull/412 KAFKA-2734: kafka-console-consumer throws NoSuchElementException on n… …ot specifying topic You can merge this pull request into a Git repository by running: $ git pull https://github.com

[jira] [Created] (KAFKA-2734) kafka-console-consumer throws NoSuchElementException on not specifying topic

2015-11-03 Thread Ashish K Singh (JIRA)
Ashish K Singh created KAFKA-2734: - Summary: kafka-console-consumer throws NoSuchElementException on not specifying topic Key: KAFKA-2734 URL: https://issues.apache.org/jira/browse/KAFKA-2734 Project:

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

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

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

2015-11-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2687. -- Resolution: Fixed Issue resolved by pull request 388 [https://github.com/apache/kafka/pull/388]

[GitHub] kafka pull request: KAFKA-2687: Add support for ListGroups and Des...

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

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

2015-11-03 Thread Apache Jenkins Server
See Changes: [wangguoz] KAFKA-2441: SSL/TLS in official docs -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-2 (docker Ubuntu ubuntu) in

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

2015-11-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/406 --- 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] [Commented] (KAFKA-2441) SSL/TLS in official docs

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

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

2015-11-03 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2697: -- Assignee: Jason Gustafson (was: Onur Karaman) > add leave group logic to the consumer

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

2015-11-03 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14988276#comment-14988276 ] Jason Gustafson commented on KAFKA-2697: [~onurkaraman] Ah, didn't see your commen

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

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

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

2015-11-03 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14988271#comment-14988271 ] Jason Gustafson commented on KAFKA-2697: [~onurkaraman] I was thinking something w

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

2015-11-03 Thread Apache Jenkins Server
See Changes: [cshapi] KAFKA-2480: Add backoff timeout and support rewinds -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (Ubuntu ubuntu) in

[jira] [Resolved] (KAFKA-2481) Allow copycat sinks to request periodic invocation of put even if no new data is available

2015-11-03 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2481. -- Resolution: Fixed Reviewer: Gwen Shapira This has been resolved via https:

[jira] [Reopened] (KAFKA-2480) Handle non-CopycatExceptions from SinkTasks

2015-11-03 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reopened KAFKA-2480: -- Oops, I think this got misfiled. The actual JIRA fixed by PR 340 is KAFKA-2481. > H

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

2015-11-03 Thread Apache Jenkins Server
See Changes: [cshapi] KAFKA-2480: Add backoff timeout and support rewinds -- [...truncated 199 lines...] commitTimestamp: Long = org.apache.kafka.common.requests.Off

Re: One more Kafka Meetup hosted by LinkedIn in 2015 (this time in San Francisco) - does anyone want to talk?

2015-11-03 Thread Grant Henke
Is there a place where we can find all previously streamed/recorded meetups? Thank you, Grant On Tue, Nov 3, 2015 at 2:07 PM, Ed Yakabosky wrote: > I'm sorry to hear that Lukas. I have heard that people are starting to do > carpools via rydeful.com for some of these meetups. > > Additionally,

[jira] [Resolved] (KAFKA-2480) Handle non-CopycatExceptions from SinkTasks

2015-11-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2480. - Resolution: Fixed Issue resolved by pull request 340 [https://github.com/apache/kafka/pull/340] >

[jira] [Commented] (KAFKA-2480) Handle non-CopycatExceptions from SinkTasks

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

[GitHub] kafka pull request: KAFKA-2480: Add backoff timeout and support re...

2015-11-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/340 --- 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] [Commented] (KAFKA-2730) partition-reassignment tool stops working due to error in registerMetric

2015-11-03 Thread Hannu Valtonen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14988097#comment-14988097 ] Hannu Valtonen commented on KAFKA-2730: --- Answering Guozhang Wang's question on the m

Re: One more Kafka Meetup hosted by LinkedIn in 2015 (this time in San Francisco) - does anyone want to talk?

2015-11-03 Thread Ed Yakabosky
I'm sorry to hear that Lukas. I have heard that people are starting to do carpools via rydeful.com for some of these meetups. Additionally, we will live stream and record the presentations, so you can participate remotely. Ed On Tue, Nov 3, 2015 at 10:43 AM, Lukas Steiblys wrote: > This is sa

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

2015-11-03 Thread Apache Jenkins Server
See Changes: [cshapi] KAFKA-2716: Make Kafka core not depend on log4j-appender -- [...truncated 346 lines...] :copycat:runtime:jar :jarAll :docsJar_2_10_5 Building project 'core' with Scala versio

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

2015-11-03 Thread Apache Jenkins Server
See

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

2015-11-03 Thread Yasuhiro Matsuda (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yasuhiro Matsuda updated KAFKA-2727: Description: Currently each streaming task initializes the entire topology regardless of the

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

2015-11-03 Thread Apache Jenkins Server
See Changes: [cshapi] KAFKA-2724: ZK Auth documentation. -- [...truncated 4643 lines...] org.apache.kafka.copycat.json.JsonConverterTest > noSchemaToCopycat PASSED org.apache.kafka.copycat.json.

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

2015-11-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2698: Priority: Critical (was: Blocker) > add paused API > -- > > Key: KAFKA-

[jira] [Created] (KAFKA-2733) Distinguish metric names inside the sensor registry

2015-11-03 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-2733: Summary: Distinguish metric names inside the sensor registry Key: KAFKA-2733 URL: https://issues.apache.org/jira/browse/KAFKA-2733 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-2731) Kerberos on same host with Kafka does not find server in it's database on Ubuntu

2015-11-03 Thread Flavio Junqueira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14987915#comment-14987915 ] Flavio Junqueira commented on KAFKA-2731: - You may want to check the documentation

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

2015-11-03 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14987903#comment-14987903 ] Rajini Sivaram commented on KAFKA-2658: --- [~junrao] OK, thanks, will submit a KIP. >

[jira] [Commented] (KAFKA-2730) partition-reassignment tool stops working due to error in registerMetric

2015-11-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14987890#comment-14987890 ] Guozhang Wang commented on KAFKA-2730: -- Thanks [~gwenshap], yes I am working on this

[jira] [Commented] (KAFKA-2730) partition-reassignment tool stops working due to error in registerMetric

2015-11-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14987856#comment-14987856 ] Gwen Shapira commented on KAFKA-2730: - [~guozhang] - I assigned this to you since you

[jira] [Updated] (KAFKA-2730) partition-reassignment tool stops working due to error in registerMetric

2015-11-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2730: Assignee: Guozhang Wang > partition-reassignment tool stops working due to error in registerMetric >

[jira] [Updated] (KAFKA-2730) partition-reassignment tool stops working due to error in registerMetric

2015-11-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2730: Priority: Blocker (was: Major) > partition-reassignment tool stops working due to error in register

Re: One more Kafka Meetup hosted by LinkedIn in 2015 (this time in San Francisco) - does anyone want to talk?

2015-11-03 Thread Lukas Steiblys
This is sad news. I was looking forward to finally going to a Kafka or Samza meetup. Going to Mountain View for a meetup is just unrealistic with 2h travel time each way. Lukas -Original Message- From: Ed Yakabosky Sent: Tuesday, November 3, 2015 10:36 AM To: us...@kafka.apache.org ;

Re: One more Kafka Meetup hosted by LinkedIn in 2015 (this time in San Francisco) - does anyone want to talk?

2015-11-03 Thread Ed Yakabosky
Hi all, Two corrections to the invite: 1. The invitation is for November 18, 2015. *NOT 2016.* I was a little hasty... 2. LinkedIn has finished remodeling our broadcast room, so we are going to host the meet up in Mountain View, not San Francisco. We've arranged for speakers from H

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

2015-11-03 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2716. - Resolution: Fixed Fix Version/s: 0.9.0.0 Issue resolved by pull request 405 [https://github

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

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

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

2015-11-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/405 --- 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] [Commented] (KAFKA-2727) initialize only the part of the topology relevant to the task

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

[GitHub] kafka pull request: KAFKA-2727: Topology partial construction

2015-11-03 Thread ymatsuda
GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/411 KAFKA-2727: Topology partial construction @guozhangwang You can merge this pull request into a Git repository by running: $ git pull https://github.com/ymatsuda/kafka topology_partial_constru

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

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

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

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

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

2015-11-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/409 --- 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] [Commented] (KAFKA-2731) Kerberos on same host with Kafka does not find server in it's database on Ubuntu

2015-11-03 Thread Mohammad Abbasi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14987681#comment-14987681 ] Mohammad Abbasi commented on KAFKA-2731: Ok thanx, I'll test this soon. > Kerbero

Re: [DISCUSS] KIP-36 - Rack aware replica assignment

2015-11-03 Thread Neha Narkhede
Few suggestions on improving the KIP *If some brokers have rack, and some do not, the algorithm will thrown an > exception. This is to prevent incorrect assignment caused by user error.* In the KIP, can you clearly state the user-facing behavior when some brokers have rack information and some d

[jira] [Commented] (KAFKA-2731) Kerberos on same host with Kafka does not find server in it's database on Ubuntu

2015-11-03 Thread Flavio Junqueira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14987594#comment-14987594 ] Flavio Junqueira commented on KAFKA-2731: - I don't think the need to be different,

[jira] [Commented] (KAFKA-2731) Kerberos on same host with Kafka does not find server in it's database on Ubuntu

2015-11-03 Thread Mohammad Abbasi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14987587#comment-14987587 ] Mohammad Abbasi commented on KAFKA-2731: Thank you for response [~fpj], So keytab

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

2015-11-03 Thread Apache Jenkins Server
See Changes: [junrao] KAFKA-2719; Use wildcard classpath for dependant-libs -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (Ubuntu ubuntu)

[GitHub] kafka pull request: KAFKA-2732: Add class for ZK Auth.

2015-11-03 Thread fpj
GitHub user fpj opened a pull request: https://github.com/apache/kafka/pull/410 KAFKA-2732: Add class for ZK Auth. You can merge this pull request into a Git repository by running: $ git pull https://github.com/fpj/kafka KAFKA-2732 Alternatively you can review and apply these

[jira] [Commented] (KAFKA-2732) Add support for consumer test with ZK Auth, SASL and SSL

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

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

2015-11-03 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14987537#comment-14987537 ] Ismael Juma commented on KAFKA-2716: [~singhashish], your PR looks good to me. > Make

[jira] [Created] (KAFKA-2732) Add support for consumer test with ZK Auth, SASL and SSL

2015-11-03 Thread Flavio Junqueira (JIRA)
Flavio Junqueira created KAFKA-2732: --- Summary: Add support for consumer test with ZK Auth, SASL and SSL Key: KAFKA-2732 URL: https://issues.apache.org/jira/browse/KAFKA-2732 Project: Kafka

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

2015-11-03 Thread Apache Jenkins Server
See Changes: [junrao] KAFKA-2719; Use wildcard classpath for dependant-libs -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (Ubuntu ubuntu) i

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

2015-11-03 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2719: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request 400 [https:/

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

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

[GitHub] kafka pull request: KAFKA-2719: Use wildcard classpath for dependa...

2015-11-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/400 --- 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] [Commented] (KAFKA-2731) Kerberos on same host with Kafka does not find server in it's database on Ubuntu

2015-11-03 Thread Flavio Junqueira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14987487#comment-14987487 ] Flavio Junqueira commented on KAFKA-2731: - [~mabbasi90.class] You also need to con

  1   2   >