[jira] [Commented] (KAFKA-2816) selector.poll() no longer throws IOException

[ https://issues.apache.org/jira/browse/KAFKA-2816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15001768#comment-15001768 ] Dong Lin commented on KAFKA-2816: - I just checked the code. poll(timeout) calls select(tim

[jira] [Created] (KAFKA-2816) selector.poll() no longer throws IOException

Jun Rao created KAFKA-2816: -- Summary: selector.poll() no longer throws IOException Key: KAFKA-2816 URL: https://issues.apache.org/jira/browse/KAFKA-2816 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-2813) selector doesn't close socket connection on non-IOExceptions

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

[jira] [Resolved] (KAFKA-2813) selector doesn't close socket connection on non-IOExceptions

[ https://issues.apache.org/jira/browse/KAFKA-2813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2813. Resolution: Fixed Issue resolved by pull request 501 [https://github.com/apache/kafka/pull/501] > selector

[GitHub] kafka pull request: KAFKA-2813: selector doesn't close socket conn...

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

Github user ZoneMayor closed the pull request at: https://github.com/apache/kafka/pull/228 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is en

[GitHub] kafka pull request: more test

GitHub user ZoneMayor reopened a pull request: https://github.com/apache/kafka/pull/228 more test You can merge this pull request into a Git repository by running: $ git pull https://github.com/ZoneMayor/kafka trunk Alternatively you can review and apply these changes as the

[GitHub] kafka pull request: more test

Github user ZoneMayor closed the pull request at: https://github.com/apache/kafka/pull/228 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is en

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

See Changes: [junrao] KAFKA2805; RecordAccumulator request timeout not enforced when all [junrao] MINOR: Do not collect zk persistent data by default -- [...truncated 1410 lines...] kafka.log.L

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

See Changes: [junrao] KAFKA2805; RecordAccumulator request timeout not enforced when all [junrao] MINOR: Do not collect zk persistent data by default -- Started by an SCM change [EnvInject] - Lo

[jira] [Created] (KAFKA-2815) unit test failure in org.apache.kafka.streams.processor.internals.KafkaStreamingPartitionAssignorTest

Jun Rao created KAFKA-2815: -- Summary: unit test failure in org.apache.kafka.streams.processor.internals.KafkaStreamingPartitionAssignorTest Key: KAFKA-2815 URL: https://issues.apache.org/jira/browse/KAFKA-2815

[GitHub] kafka pull request: MINOR: Do not collect zk persistent data by de...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/504 --- 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-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 ] Jun Rao resolved KAFKA-2805. Resolution: Fixed Issue resolved by pull request 503 [https://github.com/apache/kafka/pull/503] > RecordAcc

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

[GitHub] kafka pull request: KAFKA-2805

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/503 --- 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: Do not collect zk persistent data by de...

GitHub user granders opened a pull request: https://github.com/apache/kafka/pull/504 MINOR: Do not collect zk persistent data by default In system tests zookeeper service, it is overkill and space-intensive to collect zookeeper data logs by default. This minor patch turns off defaul

[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=15001559#comment-15001559 ] Mayuresh Gharat commented on KAFKA-2805: Yes. That s right. The check was put in p

[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=15001495#comment-15001495 ] ASF GitHub Bot commented on KAFKA-2805: --- GitHub user MayureshGharat opened a pull re

[GitHub] kafka pull request: KAFKA-2805

GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/503 KAFKA-2805 Removed the check for only those expiring batches whose metadata is unavailable. Now the batches will be expired irrespective of whether the leader is available or not, as soon as

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

See Changes: [cshapi] KAFKA-2807: Move ThroughputThrottler back to tools jar to fix upgrade [wangguoz] KAFKA-2763: better stream task assignment -- [...truncated 3877 lines...] org.apache.kafka.

[GitHub] kafka pull request: TRIVIAL: provide clearer error in describe gro...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/502 TRIVIAL: provide clearer error in describe group when group is inactive You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka trivial

[jira] [Commented] (KAFKA-2813) selector doesn't close socket connection on non-IOExceptions

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

[GitHub] kafka pull request: KAFKA-2813: selector doesn't close socket conn...

GitHub user junrao opened a pull request: https://github.com/apache/kafka/pull/501 KAFKA-2813: selector doesn't close socket connection on non-IOExceptions Patched Selector.poll() to close the connection on any exception. You can merge this pull request into a Git repository by runn

[jira] [Created] (KAFKA-2814) Kafka Connect system tests using REST interface fail on AWS

Ewen Cheslack-Postava created KAFKA-2814: Summary: Kafka Connect system tests using REST interface fail on AWS Key: KAFKA-2814 URL: https://issues.apache.org/jira/browse/KAFKA-2814 Project: Ka

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

See Changes: [cshapi] KAFKA-2807: Move ThroughputThrottler back to tools jar to fix upgrade [wangguoz] KAFKA-2763: better stream task assignment -- Started by an SCM change [EnvInject] - Loading

[jira] [Resolved] (KAFKA-2763) Reduce stream task migrations and initialization costs

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

[jira] [Commented] (KAFKA-2763) Reduce stream task migrations and initialization costs

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

[GitHub] kafka pull request: KAFKA-2763: better stream task assignment

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/497 --- 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-2807: Move ThroughputThrottler back to t...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/499 --- 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-2807) Movement of throughput throttler to common broke upgrade tests

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

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-2807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2807: Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Movement of throughput throttler to c

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

[ https://issues.apache.org/jira/browse/KAFKA-2807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2807: Fix Version/s: (was: 0.9.0.1) 0.9.1.0 > Movement of throughput throttler to c

[jira] [Created] (KAFKA-2813) selector doesn't close socket connection on non-IOExceptions

Jun Rao created KAFKA-2813: -- Summary: selector doesn't close socket connection on non-IOExceptions Key: KAFKA-2813 URL: https://issues.apache.org/jira/browse/KAFKA-2813 Project: Kafka Issue Type: B

[jira] [Commented] (KAFKA-2812) Enhance new consumer integration test coverage

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

[GitHub] kafka pull request: KAFKA-2812: improve consumer integration tests

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/500 KAFKA-2812: improve consumer integration tests You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-2812 Alternatively you ca

[jira] [Created] (KAFKA-2812) Enhance new consumer integration test coverage

Jason Gustafson created KAFKA-2812: -- Summary: Enhance new consumer integration test coverage Key: KAFKA-2812 URL: https://issues.apache.org/jira/browse/KAFKA-2812 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-2811) Add standby tasks

[ https://issues.apache.org/jira/browse/KAFKA-2811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yasuhiro Matsuda reassigned KAFKA-2811: --- Assignee: Yasuhiro Matsuda > Add standby tasks > - > >

[jira] [Created] (KAFKA-2811) Add standby tasks

Yasuhiro Matsuda created KAFKA-2811: --- Summary: Add standby tasks Key: KAFKA-2811 URL: https://issues.apache.org/jira/browse/KAFKA-2811 Project: Kafka Issue Type: Sub-task Componen

[jira] [Assigned] (KAFKA-2763) Reduce stream task migrations and initialization costs

[ https://issues.apache.org/jira/browse/KAFKA-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yasuhiro Matsuda reassigned KAFKA-2763: --- Assignee: Yasuhiro Matsuda > Reduce stream task migrations and initialization costs >

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

[ https://issues.apache.org/jira/browse/KAFKA-2807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2807: - Assignee: Ewen Cheslack-Postava (was: Geoff Anderson) Reviewer: Gwen

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

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

[GitHub] kafka pull request: KAFKA-2807: Move ThroughputThrottler back to t...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/499 KAFKA-2807: Move ThroughputThrottler back to tools jar to fix upgrade tests. You can merge this pull request into a Git repository by running: $ git pull https://github.com/ewencp/kafka kafka-2

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

See

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

See Changes: [cshapi] KAFKA-2790: doc improvements -- [...truncated 1856 lines...] kafka.admin.AddPartitionsTest > testTopicDoesNotExist PASSED kafka.admin.AddPartitionsTest > testIncrementPart

[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: --- Assignee: Mayuresh Gharat (was: Jason Gustafson) > RecordAccumulator request timeout not enfo

[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=15001040#comment-15001040 ] Jason Gustafson commented on KAFKA-2805: Works for me. I'll assign back to you. >

[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=15001024#comment-15001024 ] Mayuresh Gharat commented on KAFKA-2805: Hi Jason, I was debugging to find exactl

[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=15001004#comment-15001004 ] Jason Gustafson commented on KAFKA-2805: Went ahead and assigned to myself to try

[jira] [Assigned] (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 reassigned KAFKA-2805: -- Assignee: Jason Gustafson (was: Mayuresh Gharat) > RecordAccumulator request timeout n

[jira] [Commented] (KAFKA-2809) Improve documentation linking

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

[jira] [Updated] (KAFKA-2809) Improve documentation linking

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

[GitHub] kafka pull request: KAFKA-2809: Improve documentation linking

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/498 KAFKA-2809: Improve documentation linking Often it is useful to link to a specific header within the documentation. Especially when referencing docs in the mailing lists. This adds anchor

[jira] [Commented] (KAFKA-2808) Support auto.create.topics.enable with automatic WRITE permissions for creator

[ https://issues.apache.org/jira/browse/KAFKA-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15000985#comment-15000985 ] Parth Brahmbhatt commented on KAFKA-2808: - [~tgraves] your last comment is what I

[jira] [Created] (KAFKA-2810) Build a small subset of system tests on PR

Geoff Anderson created KAFKA-2810: - Summary: Build a small subset of system tests on PR Key: KAFKA-2810 URL: https://issues.apache.org/jira/browse/KAFKA-2810 Project: Kafka Issue Type: Wish

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

See Changes: [cshapi] KAFKA-2790: doc improvements -- [...truncated 3654 lines...] kafka.log.BrokerCompressionTest > testBrokerSideCompression[0] PASSED kafka.log.BrokerCompressionTest > testBr

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

[ https://issues.apache.org/jira/browse/KAFKA-2807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15000969#comment-15000969 ] Neha Narkhede commented on KAFKA-2807: -- We don't want our tests to fail, so marking t

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

[ https://issues.apache.org/jira/browse/KAFKA-2807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-2807: - Priority: Blocker (was: Major) > Movement of throughput throttler to common broke upgrade tests >

[jira] [Created] (KAFKA-2809) Improve documentation linking

Grant Henke created KAFKA-2809: -- Summary: Improve documentation linking Key: KAFKA-2809 URL: https://issues.apache.org/jira/browse/KAFKA-2809 Project: Kafka Issue Type: Improvement Com

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

[ https://issues.apache.org/jira/browse/KAFKA-2807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15000934#comment-15000934 ] Ewen Cheslack-Postava commented on KAFKA-2807: -- [~geoffra] Hmm, I moved it in

[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 ] Jun Rao updated KAFKA-2805: --- Priority: Blocker (was: Major) > RecordAccumulator request timeout not enforced when all brokers are gone > -

[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=15000891#comment-15000891 ] Jun Rao commented on KAFKA-2805: [~mgharat], since this blocks the 0.9.0.0 release, do you

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

[jira] [Resolved] (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 resolved KAFKA-2790. - Resolution: Fixed Issue resolved by pull request 491 [https://github.com/apache/kafka/pull/491] >

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

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/491 --- 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-2808) Support auto.create.topics.enable with automatic WRITE permissions for creator

[ https://issues.apache.org/jira/browse/KAFKA-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15000880#comment-15000880 ] Thomas Graves commented on KAFKA-2808: -- Sorry just realized perhaps what you were thi

[jira] [Commented] (KAFKA-2808) Support auto.create.topics.enable with automatic WRITE permissions for creator

[ https://issues.apache.org/jira/browse/KAFKA-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15000876#comment-15000876 ] Thomas Graves commented on KAFKA-2808: -- I'm sure there are cases you wouldn't want th

[jira] [Comment Edited] (KAFKA-2808) Support auto.create.topics.enable with automatic WRITE permissions for creator

[ https://issues.apache.org/jira/browse/KAFKA-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15000874#comment-15000874 ] Thomas Graves edited comment on KAFKA-2808 at 11/11/15 6:44 PM:

[jira] [Commented] (KAFKA-2808) Support auto.create.topics.enable with automatic WRITE permissions for creator

[ https://issues.apache.org/jira/browse/KAFKA-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15000874#comment-15000874 ] Thomas Graves commented on KAFKA-2808: -- I haven't looked a the pull request but I'm n

[jira] [Commented] (KAFKA-2808) Support auto.create.topics.enable with automatic WRITE permissions for creator

[ https://issues.apache.org/jira/browse/KAFKA-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15000865#comment-15000865 ] Parth Brahmbhatt commented on KAFKA-2808: - Ideally we would always give admin acce

[jira] [Commented] (KAFKA-2808) Support auto.create.topics.enable with automatic WRITE permissions for creator

[ https://issues.apache.org/jira/browse/KAFKA-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15000828#comment-15000828 ] Thomas Graves commented on KAFKA-2808: -- ccd [~parth.brahmbhatt] > Support auto.creat

[jira] [Created] (KAFKA-2808) Support auto.create.topics.enable with automatic WRITE permissions for creator

Thomas Graves created KAFKA-2808: Summary: Support auto.create.topics.enable with automatic WRITE permissions for creator Key: KAFKA-2808 URL: https://issues.apache.org/jira/browse/KAFKA-2808 Project

[jira] [Commented] (KAFKA-2763) Reduce stream task migrations and initialization costs

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

[GitHub] kafka pull request: KAFKA-2763: better stream task assignment

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/497 KAFKA-2763: better stream task assignment @guozhangwang When the rebalance happens each consumer reports the following information to the coordinator. * Client UUID (a unique id assign

[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=15000651#comment-15000651 ] Luke Steensen commented on KAFKA-2805: -- [~mgharat] To answer your question from the m

[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 ] Jun Rao updated KAFKA-2805: --- Fix Version/s: 0.9.0.0 Marking this as an 0.9.0.0 blocker for now. > RecordAccumulator request timeout not en

[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=15000633#comment-15000633 ] Jun Rao commented on KAFKA-2805: [~mgharat], I am not sure if the current logic works. If

[jira] [Updated] (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 ] Jun Rao updated KAFKA-2790: --- Priority: Blocker (was: Major) > Kafka 0.9.0 doc improvement > --- > >

[jira] [Commented] (KAFKA-2771) Add SSL Rolling Upgrade Test to System Tests

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

[GitHub] kafka pull request: KAFKA-2771: Added rolling upgrade system test ...

GitHub user benstopford opened a pull request: https://github.com/apache/kafka/pull/496 KAFKA-2771: Added rolling upgrade system test (docktape) for SSL This still needs a final run of the full system test suite. I've run this test and the replication_test.py (which is the other tes

[jira] [Comment Edited] (KAFKA-2806) Allow Kafka System Tests under different JDK versions

[ https://issues.apache.org/jira/browse/KAFKA-2806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15000224#comment-15000224 ] Ismael Juma edited comment on KAFKA-2806 at 11/11/15 10:54 AM: -

[jira] [Commented] (KAFKA-2806) Allow Kafka System Tests under different JDK versions

[ https://issues.apache.org/jira/browse/KAFKA-2806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15000224#comment-15000224 ] Ismael Juma commented on KAFKA-2806: I don't think this is a Scala-specific issue. In