[jira] [Created] (KAFKA-2807) Movement of throughput throttler to common broke upgrade tests

Geoff Anderson created KAFKA-2807: - Summary: Movement of throughput throttler to common broke upgrade tests Key: KAFKA-2807 URL: https://issues.apache.org/jira/browse/KAFKA-2807 Project: Kafka

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

See Changes: [wangguoz] KAFKA-2770: Catch and ignore WakeupException for commit upon closing -- [...truncated 6683 lines...] org.apache.kafka.connect.json.JsonConverterTest > nullToConnect PASSED

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

See

[jira] [Commented] (KAFKA-2805) RecordAccumulator request timeout not enforced when all brokers are gone

[ https://issues.apache.org/jira/browse/KAFKA-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1424#comment-1424 ] Mayuresh Gharat commented on KAFKA-2805: [~hachikuji] My producer was on trunk whe

[jira] [Updated] (KAFKA-2805) RecordAccumulator request timeout not enforced when all brokers are gone

[ https://issues.apache.org/jira/browse/KAFKA-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2805: --- Summary: RecordAccumulator request timeout not enforced when all brokers are gone (was: Recor

Build failed in Jenkins: kafka_0.9.0_jdk7 #7

See Changes: [wangguoz] KAFKA-2770: Catch and ignore WakeupException for commit upon closing -- [...truncated 1559 lines...] kafka.security.auth.ZkAuthorizationTest > testDelete PASSED kafka.secur

[jira] [Commented] (KAFKA-2805) RecordAccumulator request timeout only enforced if partition leader is unknown

[ https://issues.apache.org/jira/browse/KAFKA-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1413#comment-1413 ] Jason Gustafson commented on KAFKA-2805: [~mgharat] I was on trunk when I reproduc

[jira] [Commented] (KAFKA-2805) RecordAccumulator request timeout only enforced if partition leader is unknown

[ https://issues.apache.org/jira/browse/KAFKA-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999884#comment-14999884 ] Mayuresh Gharat commented on KAFKA-2805: I did this experiment : 1) I created a t

[jira] [Resolved] (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:all-tabpanel ] Guozhang Wang resolved KAFKA-2770. -- Resolution: Fixed Issue resolved by pull request 470 [https://github.com/apache/kafka/pull/470]

[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=14999872#comment-14999872 ] ASF GitHub Bot commented on KAFKA-2770: --- Github user asfgit closed the pull request

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

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/470 --- 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-2806) Allow Kafka System Tests under different JDK versions

Guozhang Wang created KAFKA-2806: Summary: Allow Kafka System Tests under different JDK versions Key: KAFKA-2806 URL: https://issues.apache.org/jira/browse/KAFKA-2806 Project: Kafka Issue Typ

[jira] [Updated] (KAFKA-2805) RecordAccumulator request timeout only enforced if partition leader is unknown

[ https://issues.apache.org/jira/browse/KAFKA-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2805: --- Description: When no brokers are left in the cluster, the producer seems not to enforce the r

[GitHub] kafka pull request: add example to send customized message by usin...

GitHub user microwishing opened a pull request: https://github.com/apache/kafka/pull/495 add example to send customized message by using serializer based on 0.8.2.2. anyone can help? You can merge this pull request into a Git repository by running: $ git pull https://github.com

[jira] [Commented] (KAFKA-2805) RecordAccumulator request timeout only enforced if partition leader is unknown

[ https://issues.apache.org/jira/browse/KAFKA-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999858#comment-14999858 ] Jason Gustafson commented on KAFKA-2805: I was able to reproduce this following th

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

See Changes: [junrao] KAFKA-2801; Process any remaining data in SSL network read buffer after -- [...truncated 3355 lines...] org.apache.kafka.clients.producer.internals.BufferPoolTest > testBlo

[jira] [Commented] (KAFKA-2805) RecordAccumulator request timeout only enforced if partition leader is unknown

[ https://issues.apache.org/jira/browse/KAFKA-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999844#comment-14999844 ] Mayuresh Gharat commented on KAFKA-2805: Yes. That was the thinking. Also from the

[jira] [Assigned] (KAFKA-2805) RecordAccumulator request timeout only enforced if partition leader is unknown

[ https://issues.apache.org/jira/browse/KAFKA-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat reassigned KAFKA-2805: -- Assignee: Mayuresh Gharat > RecordAccumulator request timeout only enforced if partitio

[jira] [Updated] (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:all-tabpanel ] Jun Rao updated KAFKA-2770: --- Fix Version/s: (was: 0.9.0.1) 0.9.0.0 > Race condition causes Mirror Maker to hang duri

[jira] [Updated] (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:all-tabpanel ] Jun Rao updated KAFKA-2770: --- Priority: Blocker (was: Major) > Race condition causes Mirror Maker to hang during shutdown (new consumer) >

[jira] [Commented] (KAFKA-2805) RecordAccumulator request timeout only enforced if partition leader is unknown

[ https://issues.apache.org/jira/browse/KAFKA-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999828#comment-14999828 ] Jun Rao commented on KAFKA-2805: >From the RB, that's the explanation from Mayuresh. In t

[jira] [Commented] (KAFKA-2805) RecordAccumulator request timeout only enforced if partition leader is unknown

[ https://issues.apache.org/jira/browse/KAFKA-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999792#comment-14999792 ] Jason Gustafson commented on KAFKA-2805: [~mgharat] [~becket_qin] Do you have any

[jira] [Work started] (KAFKA-2796) add support for reassignment partition to specified logdir

[ https://issues.apache.org/jira/browse/KAFKA-2796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2796 started by Yonghui Yang. --- > add support for reassignment partition to specified logdir >

[jira] [Created] (KAFKA-2805) RecordAccumulator request timeout only enforced if partition leader is unknown

Jason Gustafson created KAFKA-2805: -- Summary: RecordAccumulator request timeout only enforced if partition leader is unknown Key: KAFKA-2805 URL: https://issues.apache.org/jira/browse/KAFKA-2805 Proj

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

See Changes: [wangguoz] KAFKA-2752: Follow up to fix checkstlye [junrao] KAFKA-2801; Process any remaining data in SSL network read buffer after -- [...truncated 1403 lines...] kafka.log.LogTes

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

See Changes: [junrao] KAFKA-2788; Allow specifying principals with comman in ACL CLI. [cshapi] KAFKA-2793: Use ByteArrayDeserializer instead of StringDeserializer for [wangguoz] KAFKA-2752: Add VerifiableSource/Sink connectors and rol

[jira] [Updated] (KAFKA-2801) Data read from network not processed by SSL transport layer

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

[jira] [Commented] (KAFKA-2801) Data read from network not processed by SSL transport layer

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

[jira] [Updated] (KAFKA-2803) Add hard bounce system test for distributed Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-2803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2803: - Status: Patch Available (was: Open) > Add hard bounce system test for distributed

[GitHub] kafka pull request: KAFKA-2801: Process any remaining data in SSL ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/493 --- 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-2803) Add hard bounce system test for distributed Kafka Connect

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

[GitHub] kafka pull request: KAFKA-2803: Add hard bounce system test for Ka...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/494 KAFKA-2803: Add hard bounce system test for Kafka Connect. You can merge this pull request into a Git repository by running: $ git pull https://github.com/ewencp/kafka kafka-2803-connect-hard-b

[jira] [Created] (KAFKA-2804) Create / Update changelog topics upon state store initialization

Guozhang Wang created KAFKA-2804: Summary: Create / Update changelog topics upon state store initialization Key: KAFKA-2804 URL: https://issues.apache.org/jira/browse/KAFKA-2804 Project: Kafka

[jira] [Created] (KAFKA-2803) Add hard bounce system test for distributed Kafka Connect

Ewen Cheslack-Postava created KAFKA-2803: Summary: Add hard bounce system test for distributed Kafka Connect Key: KAFKA-2803 URL: https://issues.apache.org/jira/browse/KAFKA-2803 Project: Kafka

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

See -- Started by user gwenshap [EnvInject] - Loading node environment variables. Building remotely on ubuntu3 (Ubuntu ubuntu legacy-ubuntu) in workspace

[jira] [Created] (KAFKA-2802) Add integration tests for Kafka Streams

Guozhang Wang created KAFKA-2802: Summary: Add integration tests for Kafka Streams Key: KAFKA-2802 URL: https://issues.apache.org/jira/browse/KAFKA-2802 Project: Kafka Issue Type: Sub-task

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

See Changes: [wangguoz] KAFKA-2752: Follow up to fix checkstlye -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (Ubuntu ubuntu) in workspace

[jira] [Updated] (KAFKA-1892) System tests for the new consumer and co-ordinator

[ https://issues.apache.org/jira/browse/KAFKA-1892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1892: - Resolution: Won't Fix Status: Resolved (was: Patch Available) We have added integration t

[jira] [Commented] (KAFKA-2752) Add clean bounce system test for distributed Copycat

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

[GitHub] kafka pull request: KAFKA-2752: Follow up to fix checkstlye

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/492 --- 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-2801) Data read from network not processed by SSL transport layer

[ https://issues.apache.org/jira/browse/KAFKA-2801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-2801: -- Status: Patch Available (was: Open) Have run all existing unit tests. Can't think of an easy wa

[jira] [Commented] (KAFKA-2801) Data read from network not processed by SSL transport layer

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

[GitHub] kafka pull request: KAFKA-2801: Process any remaining data in SSL ...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/493 KAFKA-2801: Process any remaining data in SSL network read buffer after handshake Process any remaining data in the network read buffer in `SslTransportLayer` when `read()` is invoked. On hand

[jira] [Commented] (KAFKA-2752) Add clean bounce system test for distributed Copycat

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

[GitHub] kafka pull request: KAFKA-2752: Follow up to fix checkstlye

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/492 KAFKA-2752: Follow up to fix checkstlye You can merge this pull request into a Git repository by running: $ git pull https://github.com/granthenke/kafka fix Alternatively you can review and

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

See Changes: [junrao] KAFKA-2788; Allow specifying principals with comman in ACL CLI. [cshapi] KAFKA-2793: Use ByteArrayDeserializer instead of StringDeserializer for [wangguoz] KAFKA-2752: Add VerifiableSource/Sink connectors and rol

[jira] [Created] (KAFKA-2801) Data read from network not processed by SSL transport layer

Rajini Sivaram created KAFKA-2801: - Summary: Data read from network not processed by SSL transport layer Key: KAFKA-2801 URL: https://issues.apache.org/jira/browse/KAFKA-2801 Project: Kafka

[jira] [Resolved] (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:all-tabpanel ] Gwen Shapira resolved KAFKA-2793. - Resolution: Fixed Fix Version/s: 0.9.0.0 Issue resolved by pull request 482 [https://github

[jira] [Commented] (KAFKA-2799) WakupException thrown in the followup poll() could lead to data loss

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

[jira] [Resolved] (KAFKA-2799) WakupException thrown in the followup poll() could lead to data loss

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

[GitHub] kafka pull request: KAFKA-2799: skip wakeup in the follow-up poll(...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/490 --- 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] [Resolved] (KAFKA-2752) Add clean bounce system test for distributed Copycat

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

[jira] [Updated] (KAFKA-2752) Add clean bounce system test for distributed Copycat

[ https://issues.apache.org/jira/browse/KAFKA-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2752: - Fix Version/s: (was: 0.9.0.0) 0.9.0.1 > Add clean bounce system test for di

[jira] [Commented] (KAFKA-2752) Add clean bounce system test for distributed Copycat

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

[GitHub] kafka pull request: KAFKA-2752: Add VerifiableSource/Sink connecto...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/432 --- 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-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=14999498#comment-14999498 ] ASF GitHub Bot commented on KAFKA-2793: --- Github user asfgit closed the pull request

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

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/482 --- 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] [Resolved] (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 ] Jun Rao resolved KAFKA-2788. Resolution: Fixed Issue resolved by pull request 489 [https://github.com/apache/kafka/pull/489] > allow com

Jenkins build is back to normal : kafka_0.9.0_jdk7 #3

See

[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=14999468#comment-14999468 ] ASF GitHub Bot commented on KAFKA-2788: --- Github user asfgit closed the pull request

[GitHub] kafka pull request: KAFKA-2788: Allow specifying principals with c...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/489 --- 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-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=14999433#comment-14999433 ] Gwen Shapira commented on KAFKA-2790: - Hey [~junrao], Take a look. I think I addresse

[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=14999427#comment-14999427 ] ASF GitHub Bot commented on KAFKA-2790: --- GitHub user gwenshap opened a pull request:

[GitHub] kafka pull request: KAFKA-2790: doc improvements

GitHub user gwenshap opened a pull request: https://github.com/apache/kafka/pull/491 KAFKA-2790: doc improvements You can merge this pull request into a Git repository by running: $ git pull https://github.com/gwenshap/kafka KAFKA-2790 Alternatively you can review and apply t

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

See

[jira] [Commented] (KAFKA-2799) WakupException thrown in the followup poll() could lead to data loss

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

[GitHub] kafka pull request: KAFKA-2799: skip wakeup in the follow-up poll(...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/490 KAFKA-2799: skip wakeup in the follow-up poll() call. You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K2799 Alternativel

[jira] [Commented] (KAFKA-2796) add support for reassignment partition to specified logdir

[ https://issues.apache.org/jira/browse/KAFKA-2796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999364#comment-14999364 ] Guozhang Wang commented on KAFKA-2796: -- I think there are some related KIP discussion

[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=14999356#comment-14999356 ] ASF GitHub Bot commented on KAFKA-2788: --- GitHub user Parth-Brahmbhatt opened a pull

[GitHub] kafka pull request: KAFKA-2788: Allow specifying principals with c...

GitHub user Parth-Brahmbhatt opened a pull request: https://github.com/apache/kafka/pull/489 KAFKA-2788: Allow specifying principals with comman in ACL CLI. You can merge this pull request into a Git repository by running: $ git pull https://github.com/Parth-Brahmbhatt/kafka K

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

See Changes: [wangguoz] KAFKA-2795: fix potential NPE in GroupMetadataManager.addGroup -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu3 (

[jira] [Updated] (KAFKA-2796) add support for reassignment partition to specified logdir

[ https://issues.apache.org/jira/browse/KAFKA-2796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2796: - Fix Version/s: (was: 0.9.0.0) 0.9.0.1 > add support for reassignment partit

[jira] [Updated] (KAFKA-2796) add support for reassignment partition to specified logdir

[ https://issues.apache.org/jira/browse/KAFKA-2796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2796: - Assignee: Yonghui Yang (was: Neha Narkhede) > add support for reassignment partition to specified

Build failed in Jenkins: kafka_0.9.0_jdk7 #2

See Changes: [wangguoz] MINOR: update system test readme -- [...truncated 1513 lines...] kafka.security.auth.ZkAuthorizationTest > testDelete PASSED kafka.security.auth.ZkAuthorizationTest > testD

[jira] [Resolved] (KAFKA-2795) potential NPE in GroupMetadataManager

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

[jira] [Commented] (KAFKA-2795) potential NPE in GroupMetadataManager

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

[GitHub] kafka pull request: KAFKA-2795: fix potential NPE in GroupMetadata...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/488 --- 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-2800) Update outdated dependencies

Grant Henke created KAFKA-2800: -- Summary: Update outdated dependencies Key: KAFKA-2800 URL: https://issues.apache.org/jira/browse/KAFKA-2800 Project: Kafka Issue Type: Improvement Affects Ve

Re: [kafka-clients] Re: [VOTE] 0.9.0.0 Candiate 1

BTW. I created a Jenkins job for the 0.9 branch: https://builds.apache.org/job/kafka_0.9.0_jdk7/ Right now its pretty much identical to trunk, but since they may diverge, I figured we want to keep an eye on the branch separately. Gwen On Tue, Nov 10, 2015 at 11:39 AM, Jun Rao wrote: > Ewen, >

[jira] [Commented] (KAFKA-2795) potential NPE in GroupMetadataManager

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

[GitHub] kafka pull request: KAFKA-2795: fix potential NPE in GroupMetadata...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/488 KAFKA-2795: fix potential NPE in GroupMetadataManager.addGroup You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-2795 Alte

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

See -- [...truncated 1561 lines...] kafka.coordinator.GroupCoordinatorResponseTest > testSyncGroupFromUnknownGroup PASSED kafka.coordinator.GroupCoordinatorResponseTest > testJoinGroupInconsistentProto

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

See Changes: [wangguoz] MINOR: update system test readme -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-6 (docker Ubuntu ubuntu) in work

[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=14999238#comment-14999238 ] Jun Rao commented on KAFKA-2790: In the upgrade section, we should mention that 0.9.0.0 dr

Re: [kafka-clients] Re: [VOTE] 0.9.0.0 Candiate 1

There's also a concurrency bug in the GroupMetadataManager that we'd probably want fixed before the 0.9.0.0 release that Jason / Guozhang is working on: https://issues.apache.org/jira/browse/KAFKA-2795 On Tue, Nov 10, 2015 at 11:39 AM, Jun Rao wrote: > Ewen, > > Thanks for reporting that. Will f

[jira] [Commented] (KAFKA-2795) potential NPE in GroupMetadataManager

[ https://issues.apache.org/jira/browse/KAFKA-2795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999221#comment-14999221 ] Guozhang Wang commented on KAFKA-2795: -- +1. Originally it was written in the above c

[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=14999211#comment-14999211 ] Guozhang Wang commented on KAFKA-2792: -- [~ewencp] [~onurkaraman] If we fire-and-forge

[GitHub] kafka pull request: MINOR: update system test readme

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/487 --- 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-2795) potential NPE in GroupMetadataManager

[ https://issues.apache.org/jira/browse/KAFKA-2795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999194#comment-14999194 ] Onur Karaman commented on KAFKA-2795: - definitely seems better than before. > potenti

Re: [kafka-clients] Re: [VOTE] 0.9.0.0 Candiate 1

Ewen, Thanks for reporting that. Will fix that in RC2. Jun On Tue, Nov 10, 2015 at 10:41 AM, Ewen Cheslack-Postava wrote: > Jun, not sure if this is just because of the RC vs being published on the > site, but the links in the release notes aren't pointing to > issues.apache.org. They're relat

[jira] [Assigned] (KAFKA-2795) potential NPE in GroupMetadataManager

[ https://issues.apache.org/jira/browse/KAFKA-2795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2795: -- Assignee: Jason Gustafson (was: Guozhang Wang) > potential NPE in GroupMetadataManager

[jira] [Commented] (KAFKA-2795) potential NPE in GroupMetadataManager

[ https://issues.apache.org/jira/browse/KAFKA-2795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14999181#comment-14999181 ] Jason Gustafson commented on KAFKA-2795: Nice catch. Seems like we need to use the

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

See -- [...truncated 133 lines...] :36: value DEFAULT_TIMESTAMP in object OffsetCommitRequ

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

See Changes: [cshapi] KAFKA-2798: Use prefixedd configurations for Kafka Connect producer and -- [...truncated 316 lines...] :kafka-trunk-jdk7:clients:classes UP-TO-DATE :kafka-trunk-jdk7:clients

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

See Changes: [cshapi] KAFKA-2797: Only run rat when in the .git repository since it require s [cshapi] KAFKA-2792: Don't wait for a response to the leave group message when [cshapi] KAFKA-2798: Use prefixedd configurations for Kafka C

[jira] [Resolved] (KAFKA-2798) Kafka Connect distributed configs can conflict with producer/consumer configs, making it impossible to control them independently

[ https://issues.apache.org/jira/browse/KAFKA-2798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2798. - Resolution: Fixed Fix Version/s: 0.9.0.0 Issue resolved by pull request 486 [https://github

[jira] [Commented] (KAFKA-2798) Kafka Connect distributed configs can conflict with producer/consumer configs, making it impossible to control them independently

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

[GitHub] kafka pull request: KAFKA-2798: Use prefixedd configurations for K...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/486 --- 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-1810) Add IP Filtering / Whitelists-Blacklists

[ https://issues.apache.org/jira/browse/KAFKA-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1810: Fix Version/s: (was: 0.9.0.0) > Add IP Filtering / Whitelists-Blacklists >

[jira] [Updated] (KAFKA-2106) Partition balance tool between borkers

[ https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2106: Fix Version/s: (was: 0.9.0.0) > Partition balance tool between borkers > ---

  1   2   >