[VOTE] 0.9.0.0 Candiate 1

This is the first candidate for release of Apache Kafka 0.9.0.0. This a major release that includes (1) authentication (through SSL and SASL) and authorization, (2) a new java consumer, (3) a Kafka connect framework for data ingestion and egression, and (4) quotas. Since this is a major release, we

[jira] [Commented] (KAFKA-2788) allow comma when specifying principals in AclCommand

[ https://issues.apache.org/jira/browse/KAFKA-2788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14998069#comment-14998069 ] Jun Rao commented on KAFKA-2788: [~parth.brahmbhatt], one way is to not use delimiter to s

Build failed in Jenkins: _kafka_system_tests #144

See -- Started by timer Building on master in workspace [_kafka_system_tests] $ /bin/bash /tmp/hudson3075256827416348305.sh /tmp/hudson30752

[jira] [Commented] (KAFKA-2788) allow comma when specifying principals in AclCommand

[ https://issues.apache.org/jira/browse/KAFKA-2788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14998035#comment-14998035 ] Parth Brahmbhatt commented on KAFKA-2788: - Looks like we already have a valid use

[GitHub] kafka pull request: Kafka-2794: Added group support to authorizer.

GitHub user Parth-Brahmbhatt opened a pull request: https://github.com/apache/kafka/pull/483 Kafka-2794: Added group support to authorizer. You can merge this pull request into a Git repository by running: $ git pull https://github.com/Parth-Brahmbhatt/kafka KAFKA-2794 Altern

[jira] [Created] (KAFKA-2794) Add group support for authorizer acls

Parth Brahmbhatt created KAFKA-2794: --- Summary: Add group support for authorizer acls Key: KAFKA-2794 URL: https://issues.apache.org/jira/browse/KAFKA-2794 Project: Kafka Issue Type: Sub-tas

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

See Changes: [cshapi] KAFKA-2786: Only respond to SinkTask onPartitionsRevoked after the -- [...truncated 1722 lines...] kafka.log.CleanerTest > testCleanSegments PASSED kafka.log.CleanerTest >

[jira] [Commented] (KAFKA-2793) ConsoleConsumer crashes with new consumer when using keys because of incorrect deserializer

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

[GitHub] kafka pull request: KAFKA-2793: Use ByteArrayDeserializer instead ...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/482 KAFKA-2793: Use ByteArrayDeserializer instead of StringDeserializer for keys in ConsoleConsumer with new consumer. You can merge this pull request into a Git repository by running: $ git pull h

[jira] [Created] (KAFKA-2793) ConsoleConsumer crashes with new consumer when using keys because of incorrect deserializer

Ewen Cheslack-Postava created KAFKA-2793: Summary: ConsoleConsumer crashes with new consumer when using keys because of incorrect deserializer Key: KAFKA-2793 URL: https://issues.apache.org/jira/browse/KAF

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

See Changes: [cshapi] KAFKA-2786: Only respond to SinkTask onPartitionsRevoked after the -- [...truncated 125 lines...] :jar_core_2_11_7 Building project 'core' with Scala version 2.11.7 :kafka-t

[jira] [Commented] (KAFKA-2786) Only invoke SinkTask onPartitionsRevoked and commitOffsets after task has fully started

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

[jira] [Resolved] (KAFKA-2786) Only invoke SinkTask onPartitionsRevoked and commitOffsets after task has fully started

[ https://issues.apache.org/jira/browse/KAFKA-2786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2786. - Resolution: Fixed Issue resolved by pull request 476 [https://github.com/apache/kafka/pull/476] >

[GitHub] kafka pull request: KAFKA-2786: Only respond to SinkTask onPartiti...

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

[GitHub] kafka pull request: KAFKA-2772: Stabilize failures on replication ...

GitHub user granders opened a pull request: https://github.com/apache/kafka/pull/481 KAFKA-2772: Stabilize failures on replication with hard bounce You can merge this pull request into a Git repository by running: $ git pull https://github.com/confluentinc/kafka KAFKA-2772-st

[jira] [Commented] (KAFKA-2772) Stabilize replication hard bounce test

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

[jira] [Commented] (KAFKA-2773) Vagrant provision fails if num_brokers or num_zookeepers is nonzero

[ https://issues.apache.org/jira/browse/KAFKA-2773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14997927#comment-14997927 ] ASF GitHub Bot commented on KAFKA-2773: --- Github user granders closed the pull reques

[GitHub] kafka pull request: KAFKA-2773: (0.9.0 branch)Fixed broken vagrant...

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

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

See Changes: [wangguoz] KAFKA-2274: verifiable consumer and integration testing -- [...truncated 125 lines...] :jar_core_2_11_7 Building project 'core' with Scala version 2.11.7 :kafka-trunk-jdk8

[jira] [Commented] (KAFKA-2792) KafkaConsumer.close() can block unnecessarily due to leave group waiting for a reply

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

[GitHub] kafka pull request: KAFKA-2792: Don't wait for a response to the l...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/480 KAFKA-2792: Don't wait for a response to the leave group message when closing the new consumer. You can merge this pull request into a Git repository by running: $ git pull https://github.com/e

[GitHub] kafka pull request: MINOR: Refactor .gitignore

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/479 MINOR: Refactor .gitignore Refactor .gitignore with thorough coverage compiled from https://github.com/github/gitignore and inline documentation of why files are ignored. You can merge this pull

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

See Changes: [wangguoz] KAFKA-2274: verifiable consumer and integration testing -- [...truncated 96 lines...] @deprecated ^

[jira] [Updated] (KAFKA-2788) allow comma when specifying principals in AclCommand

[ https://issues.apache.org/jira/browse/KAFKA-2788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-2788: -- Assignee: Parth Brahmbhatt > allow comma when specifying principals in AclComman

[jira] [Created] (KAFKA-2792) KafkaConsumer.close() can block unnecessarily due to leave group waiting for a reply

Ewen Cheslack-Postava created KAFKA-2792: Summary: KafkaConsumer.close() can block unnecessarily due to leave group waiting for a reply Key: KAFKA-2792 URL: https://issues.apache.org/jira/browse/KAFKA-2792

[jira] [Resolved] (KAFKA-2274) Add integration test for consumer coordinator

[ https://issues.apache.org/jira/browse/KAFKA-2274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2274. -- Resolution: Fixed Issue resolved by pull request 465 [https://github.com/apache/kafka/pull/465]

[jira] [Commented] (KAFKA-2274) Add integration test for consumer coordinator

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

[GitHub] kafka pull request: KAFKA-2274: verifiable consumer and integratio...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/465 --- 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] [Created] (KAFKA-2791) remove deprecated producer properties from console-producer

Jun Rao created KAFKA-2791: -- Summary: remove deprecated producer properties from console-producer Key: KAFKA-2791 URL: https://issues.apache.org/jira/browse/KAFKA-2791 Project: Kafka Issue Type: Im

[jira] [Commented] (KAFKA-2790) Kafka 0.9.0 doc improvement

[ https://issues.apache.org/jira/browse/KAFKA-2790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14997861#comment-14997861 ] Gwen Shapira commented on KAFKA-2790: - If you don't mind, I'd like to take this one :)

[jira] [Assigned] (KAFKA-2790) Kafka 0.9.0 doc improvement

[ https://issues.apache.org/jira/browse/KAFKA-2790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira reassigned KAFKA-2790: --- Assignee: Gwen Shapira > Kafka 0.9.0 doc improvement > --- > >

[jira] [Commented] (KAFKA-2790) Kafka 0.9.0 doc improvement

[ https://issues.apache.org/jira/browse/KAFKA-2790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14997824#comment-14997824 ] Jun Rao commented on KAFKA-2790: A couple of other issues. 3. Section 7.5 ZooKeeper Authe

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

See Changes: [wangguoz] KAFKA-2769; Multi-consumer integration tests for consumer assignment -- [...truncated 96 lines...] @deprecated ^

[jira] [Created] (KAFKA-2790) Kafka 0.9.0 doc improvement

Jun Rao created KAFKA-2790: -- Summary: Kafka 0.9.0 doc improvement Key: KAFKA-2790 URL: https://issues.apache.org/jira/browse/KAFKA-2790 Project: Kafka Issue Type: Improvement Affects Versions: 0

[jira] [Resolved] (KAFKA-2696) New KafkaProducer documentation doesn't include all necessary config properties

[ https://issues.apache.org/jira/browse/KAFKA-2696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2696. - Resolution: Won't Fix > New KafkaProducer documentation doesn't include all necessary config > pr

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

See Changes: [cshapi] KAFKA-2379: Add basic documentation for Kafka Connect. [cshapi] KAFKA-2773: Fixed broken vagrant provision scripts for static zk/broker [wangguoz] KAFKA-2769; Multi-consumer integration tests for consumer assignm

[jira] [Work started] (KAFKA-2769) Integration tests for multi-consumer assignment including session timeouts

[ https://issues.apache.org/jira/browse/KAFKA-2769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2769 started by Anna Povzner. --- > Integration tests for multi-consumer assignment including session timeouts >

[jira] [Resolved] (KAFKA-2769) Integration tests for multi-consumer assignment including session timeouts

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

[jira] [Commented] (KAFKA-2769) Integration tests for multi-consumer assignment including session timeouts

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

[GitHub] kafka pull request: KAFKA-2769: Multi-consumer integration tests f...

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

See -- [...truncated 96 lines...] @deprecated ^ :389: class BrokerEndPoint in objec

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

See Changes: [cshapi] KAFKA-2379: Add basic documentation for Kafka Connect. [cshapi] KAFKA-2773: Fixed broken vagrant provision scripts for static zk/broker -- [...truncated 96 lines...] @depre

[jira] [Commented] (KAFKA-2773) Vagrant provision fails if num_brokers or num_zookeepers is nonzero

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

[jira] [Updated] (KAFKA-2773) Vagrant provision fails if num_brokers or num_zookeepers is nonzero

[ https://issues.apache.org/jira/browse/KAFKA-2773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2773: Resolution: Fixed Fix Version/s: 0.9.0.0 Status: Resolved (was: Patch Available)

[GitHub] kafka pull request: KAFKA-2773: Fixed broken vagrant provision scr...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/454 --- 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-2379) Add Copycat documentation

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

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

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

[GitHub] kafka pull request: KAFKA-2379: Add basic documentation for Kafka ...

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

[GitHub] kafka pull request: MINOR: remove Kafka Streams in 0.9.0

Github user guozhangwang closed the pull request at: https://github.com/apache/kafka/pull/474 --- 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-jdk8 #121

See Changes: [junrao] KAFKA-2785; Include Kafka Connect jars in releaseTarGz. -- [...truncated 4821 lines...] org.apache.kafka.connect.json.JsonConverterTest > nullToConnect PASSED org.apache.ka

[jira] [Created] (KAFKA-2789) Update upgrade system test to catch issue reported in KAFKA-2756

Geoff Anderson created KAFKA-2789: - Summary: Update upgrade system test to catch issue reported in KAFKA-2756 Key: KAFKA-2789 URL: https://issues.apache.org/jira/browse/KAFKA-2789 Project: Kafka

[jira] [Commented] (KAFKA-2788) allow comma when specifying principals in AclCommand

[ https://issues.apache.org/jira/browse/KAFKA-2788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14997702#comment-14997702 ] Jun Rao commented on KAFKA-2788: [~parth.brahmbhatt], could you comment on this? Would it

[jira] [Created] (KAFKA-2788) allow comma when specifying principals in AclCommand

Jun Rao created KAFKA-2788: -- Summary: allow comma when specifying principals in AclCommand Key: KAFKA-2788 URL: https://issues.apache.org/jira/browse/KAFKA-2788 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-2784) Mirror maker should swallow exceptions during shutdown.

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

[jira] [Updated] (KAFKA-2784) Mirror maker should swallow exceptions during shutdown.

[ https://issues.apache.org/jira/browse/KAFKA-2784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2784: Status: Patch Available (was: Open) > Mirror maker should swallow exceptions during shutdown. > ---

[GitHub] kafka pull request: KAFKA-2784: swallow exceptions when mirror mak...

GitHub user becketqin opened a pull request: https://github.com/apache/kafka/pull/478 KAFKA-2784: swallow exceptions when mirror maker exits. You can merge this pull request into a Git repository by running: $ git pull https://github.com/becketqin/kafka KAFKA-2784 Alternative

[jira] [Resolved] (KAFKA-2777) Examples module needs an example of new consumer

[ https://issues.apache.org/jira/browse/KAFKA-2777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2777. - Resolution: Fixed > Examples module needs an example of new consumer > ---

[jira] [Commented] (KAFKA-2777) Examples module needs an example of new consumer

[ https://issues.apache.org/jira/browse/KAFKA-2777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14997686#comment-14997686 ] Gwen Shapira commented on KAFKA-2777: - you are right, not sure how I missed that :) >

[jira] [Updated] (KAFKA-2787) Refactor gradle build

[ https://issues.apache.org/jira/browse/KAFKA-2787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-2787: --- Status: Patch Available (was: Open) > Refactor gradle build > - > >

[jira] [Commented] (KAFKA-2787) Refactor gradle build

[ https://issues.apache.org/jira/browse/KAFKA-2787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14997683#comment-14997683 ] ASF GitHub Bot commented on KAFKA-2787: --- GitHub user granthenke opened a pull reques

[GitHub] kafka pull request: KAFKA-2787: Refactor gradle build

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/477 KAFKA-2787: Refactor gradle build This is a first pass. I stopped here given its already a decent amount of change. I will follow up with more in another pull request if this is received well

[jira] [Commented] (KAFKA-2777) Examples module needs an example of new consumer

[ https://issues.apache.org/jira/browse/KAFKA-2777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14997680#comment-14997680 ] Guozhang Wang commented on KAFKA-2777: -- [~gwenshap] I think current kafka.examples.Co

[jira] [Created] (KAFKA-2787) Refactor gradle build

Grant Henke created KAFKA-2787: -- Summary: Refactor gradle build Key: KAFKA-2787 URL: https://issues.apache.org/jira/browse/KAFKA-2787 Project: Kafka Issue Type: Task Components: build

[jira] [Commented] (KAFKA-2786) Only invoke SinkTask onPartitionsRevoked and commitOffsets after task has fully started

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

[GitHub] kafka pull request: KAFKA-2786: Only respond to SinkTask onPartiti...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/476 KAFKA-2786: Only respond to SinkTask onPartitionsRevoked after the WorkerSinkTask has finished starting up. You can merge this pull request into a Git repository by running: $ git pull https://

[jira] [Created] (KAFKA-2786) Only invoke SinkTask onPartitionsRevoked and commitOffsets after task has fully started

Ewen Cheslack-Postava created KAFKA-2786: Summary: Only invoke SinkTask onPartitionsRevoked and commitOffsets after task has fully started Key: KAFKA-2786 URL: https://issues.apache.org/jira/browse/KAFKA-2

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

See Changes: [junrao] KAFKA-2785; Include Kafka Connect jars in releaseTarGz. -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-5 (docker U

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

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

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

See Changes: [wangguoz] MINOR: Make sure generated docs don't get checked in -- [...truncated 1714 lines...] kafka.api.PlaintextProducerSendTest > testWrongSerializer PASSED kafka.api.ApiUtilsTe

[GitHub] kafka pull request: KAFKA-2379: Add basic documentation for Kafka ...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/475 KAFKA-2379: Add basic documentation for Kafka Connect. You can merge this pull request into a Git repository by running: $ git pull https://github.com/ewencp/kafka kafka-2379-connect-docs Alter

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

[ https://issues.apache.org/jira/browse/KAFKA-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2379: - Reviewer: Gwen Shapira Status: Patch Available (was: Open) > Add Copycat do

[GitHub] kafka pull request: MINOR: remove Kafka Streams in 0.9.0

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/474 MINOR: remove Kafka Streams in 0.9.0 You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka removeKStream Alternatively you can

[jira] [Updated] (KAFKA-2785) Copycat jars not included in release tar gz

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

[jira] [Commented] (KAFKA-2785) Copycat jars not included in release tar gz

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

[GitHub] kafka pull request: KAFKA-2785: Include Kafka Connect jars in rele...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/473 --- 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-2785) Copycat jars not included in release tar gz

[ https://issues.apache.org/jira/browse/KAFKA-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2785: - Status: Patch Available (was: Open) > Copycat jars not included in release tar gz

[jira] [Commented] (KAFKA-2785) Copycat jars not included in release tar gz

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

[GitHub] kafka pull request: KAFKA-2785: Include Kafka Connect jars in rele...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/473 KAFKA-2785: Include Kafka Connect jars in releaseTarGz. You can merge this pull request into a Git repository by running: $ git pull https://github.com/ewencp/kafka kafka-2785-include-copycat-j

[jira] [Created] (KAFKA-2785) Copycat jars not included in release tar gz

Ewen Cheslack-Postava created KAFKA-2785: Summary: Copycat jars not included in release tar gz Key: KAFKA-2785 URL: https://issues.apache.org/jira/browse/KAFKA-2785 Project: Kafka Iss

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

See Changes: [cshapi] MINOR: remove old producer in config sections to align with APIs [wangguoz] MINOR: Improve exception message that gets thrown for non-existent group -- [...truncated 4107

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

See Changes: [cshapi] MINOR: remove old producer in config sections to align with APIs [wangguoz] MINOR: Improve exception message that gets thrown for non-existent group [wangguoz] MINOR: Make sure generated docs don't get checked i

[GitHub] kafka pull request: MINOR: Make sure generated docs don't get chec...

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

[GitHub] kafka pull request: KAFKA-2769: Multi-consumer integration tests f...

GitHub user apovzner opened a pull request: https://github.com/apache/kafka/pull/472 KAFKA-2769: Multi-consumer integration tests for consumer assignment incl. session timeouts and corresponding fixes -- Refactored multi-consumer integration group assignment validation tests for r

[jira] [Commented] (KAFKA-2769) Integration tests for multi-consumer assignment including session timeouts

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

Vector file of logo

Hello there, Does anyone have a Vector file of the Apache Kafka logo that we can use? Kind regards ~Peter

[jira] [Created] (KAFKA-2784) Mirror maker should swallow exceptions during shutdown.

Jiangjie Qin created KAFKA-2784: --- Summary: Mirror maker should swallow exceptions during shutdown. Key: KAFKA-2784 URL: https://issues.apache.org/jira/browse/KAFKA-2784 Project: Kafka Issue Typ

[jira] [Commented] (KAFKA-2770) Race condition causes Mirror Maker to hang during shutdown (new consumer)

[ https://issues.apache.org/jira/browse/KAFKA-2770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14997428#comment-14997428 ] Jiangjie Qin commented on KAFKA-2770: - [~guozhang] I think in addition to the changes

[GitHub] kafka pull request: Do not merge: Multi-consumer integration tests...

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

[GitHub] kafka pull request: MINOR: Improve exception message that gets thr...

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

[GitHub] kafka pull request: MINOR: remove old producer in config sections ...

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

[GitHub] kafka pull request: MINOR: Improve exception message that gets thr...

GitHub user SinghAsDev opened a pull request: https://github.com/apache/kafka/pull/471 MINOR: Improve exception message that gets thrown for non-existent group You can merge this pull request into a Git repository by running: $ git pull https://github.com/SinghAsDev/kafka Exce

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

See -- [...truncated 2400 lines...] kafka.integration.PlaintextTopicMetadataTest > testAutoCreateTopic PASSED kafka.integration.PlaintextTopicMetadataTest > testGetAllTopicMetadata PASSED kafka.integra

[jira] [Assigned] (KAFKA-2780) kafka-server-start.sh globbing issue

[ https://issues.apache.org/jira/browse/KAFKA-2780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jon Bringhurst reassigned KAFKA-2780: - Assignee: Jon Bringhurst > kafka-server-start.sh globbing issue > ---

[jira] [Updated] (KAFKA-2780) kafka-server-start.sh globbing issue

[ https://issues.apache.org/jira/browse/KAFKA-2780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jon Bringhurst updated KAFKA-2780: -- Description: When spaces are present in the path leading up to kafka-server-start.sh, kafka-ser

[jira] [Updated] (KAFKA-2773) Vagrant provision fails if num_brokers or num_zookeepers is nonzero

[ https://issues.apache.org/jira/browse/KAFKA-2773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Geoff Anderson updated KAFKA-2773: -- Status: Patch Available (was: Open) > Vagrant provision fails if num_brokers or num_zookeepers

[jira] [Commented] (KAFKA-2770) Race condition causes Mirror Maker to hang during shutdown (new consumer)

[ https://issues.apache.org/jira/browse/KAFKA-2770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14997287#comment-14997287 ] ASF GitHub Bot commented on KAFKA-2770: --- GitHub user guozhangwang opened a pull requ

[GitHub] kafka pull request: KAFKA-2770: Catch and ignore WakeupException f...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/470 KAFKA-2770: Catch and ignore WakeupException for commit upon closing You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K277

[GitHub] kafka pull request: MINOR: Make sure generated docs don't get chec...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/469 MINOR: Make sure generated docs don't get checked in You can merge this pull request into a Git repository by running: $ git pull https://github.com/granthenke/kafka generated-configs Alter

[GitHub] kafka pull request: MINOR: remove old producer in config sections ...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/468 MINOR: remove old producer in config sections to align with APIs You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka WikiUpda

Build failed in Jenkins: kafka_system_tests #143

See -- Started by user Gwen (Chen) Shapira Building on master in workspace [kafka_system_tests] $ /bin/bash /tmp/hudson84854094863440935.sh Ru

  1   2   >