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

See Changes: [harsha] KAFKA-2547; Make DynamicConfigManager to use the ZkNodeChangeNotifica… -- [...truncated 2382 lines...] kafka.api.PlaintextConsumerTest > testAutoCommitOnClose PASSED

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

See Changes: [harsha] KAFKA-2547; Make DynamicConfigManager to use the ZkNodeChangeNotifica… -- [...truncated 1475 lines...] kafka.log.LogTest > testTruncateTo PASSED kafka.log.LogTest >

[jira] [Commented] (KAFKA-725) Broker Exception: Attempt to read with a maximum offset less than start offset

[ https://issues.apache.org/jira/browse/KAFKA-725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15149970#comment-15149970 ] Manu Zhang commented on KAFKA-725: -- I can reproduce this on 0.9.0.0. The error log is [2016-01-28

Re: 0.9.0.1 RC1

Thanks everyone for voting. The results are: +1 binding = 4 votes (Ewen Cheslack-Postava, Neha Narkhede, Joel Koshy and Jun Rao) +1 non-binding = 3 votes -1 = 0 votes 0 = 0 votes The vote passes. I will release artifacts to maven central, update the dist svn and download site. Will send out an

Re: 0.9.0.1 RC1

Since the unit test failures are transient. +1 from myself. Thanks, Jun On Thu, Feb 11, 2016 at 6:55 PM, Jun Rao wrote: > This is the first candidate for release of Apache Kafka 0.9.0.1. This a > bug fix release that fixes 70 issues. > > Release Notes for the 0.9.0.1

Re: [kafka-clients] 0.9.0.1 RC1

+1 (non-binding) On Tue, Feb 16, 2016 at 8:59 PM, Joel Koshy wrote: > +1 > > On Thu, Feb 11, 2016 at 6:55 PM, Jun Rao wrote: > > > This is the first candidate for release of Apache Kafka 0.9.0.1. This a > > bug fix release that fixes 70 issues. > > > >

[jira] [Commented] (KAFKA-725) Broker Exception: Attempt to read with a maximum offset less than start offset

[ https://issues.apache.org/jira/browse/KAFKA-725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15149886#comment-15149886 ] Manu Zhang commented on KAFKA-725: -- I can reproduce this on 0.9.0.0. The error log is [2016-01-28

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

See Changes: [harsha] KAFKA-2508; Replace UpdateMetadata{Request,Response} with o.a.k.c.req��� -- [...truncated 2887 lines...] kafka.integration.SslTopicMetadataTest >

[jira] [Resolved] (KAFKA-2547) Make DynamicConfigManager to use the ZkNodeChangeNotificationListener introduced as part of KAFKA-2211

[ https://issues.apache.org/jira/browse/KAFKA-2547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani resolved KAFKA-2547. --- Resolution: Fixed Fix Version/s: 0.9.1.0 Issue resolved by pull

[jira] [Commented] (KAFKA-2547) Make DynamicConfigManager to use the ZkNodeChangeNotificationListener introduced as part of KAFKA-2211

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

[GitHub] kafka pull request: KAFKA-2547: Make DynamicConfigManager to use t...

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

[jira] [Commented] (KAFKA-2236) offset request reply racing with segment rolling

[ https://issues.apache.org/jira/browse/KAFKA-2236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15149808#comment-15149808 ] ASF GitHub Bot commented on KAFKA-2236: --- Github user jhspaybar closed the pull request at:

[GitHub] kafka pull request: KAFKA-2236; Offset request reply racing with s...

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

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

See

[jira] [Comment Edited] (KAFKA-3238) Deadlock Mirrormaker consumer not fetching any messages

[ https://issues.apache.org/jira/browse/KAFKA-3238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15149068#comment-15149068 ] Rekha Joshi edited comment on KAFKA-3238 at 2/17/16 3:46 AM: - anyone home? :)

Re: [kafka-clients] 0.9.0.1 RC1

+1 On Thu, Feb 11, 2016 at 6:55 PM, Jun Rao wrote: > This is the first candidate for release of Apache Kafka 0.9.0.1. This a > bug fix release that fixes 70 issues. > > Release Notes for the 0.9.0.1 release >

[jira] [Updated] (KAFKA-2508) Replace UpdateMetadata{Request,Response} with org.apache.kafka.common.requests equivalent

[ https://issues.apache.org/jira/browse/KAFKA-2508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-2508: -- Resolution: Fixed Fix Version/s: 0.9.1.0 Status: Resolved

[jira] [Commented] (KAFKA-2508) Replace UpdateMetadata{Request,Response} with org.apache.kafka.common.requests equivalent

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

[GitHub] kafka pull request: KAFKA-2508: Replace UpdateMetadata{Request,Res...

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

[GitHub] kafka pull request: HOTFIX: release resources on abrupt terminatio...

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/925 HOTFIX: release resources on abrupt termination of stream threads Currently the resources, such as the state dir locks, are not release when a stream thread is abruptly terminated.

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15149659#comment-15149659 ] Parth Brahmbhatt commented on KAFKA-1696: - [~gwenshap] [~harsha_ch] [~singhashish] I posted an

[jira] [Commented] (KAFKA-3199) LoginManager should allow using an existing Subject

[ https://issues.apache.org/jira/browse/KAFKA-3199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15149619#comment-15149619 ] Sriharsha Chintalapani commented on KAFKA-3199: --- [~adam.kunicki] what happens when a thread

[GitHub] kafka pull request: MINOR: Doc of topic-level configuration is mis...

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

[jira] [Commented] (KAFKA-3242) "Add Partition" log message doesn't actually indicate adding a partition

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

[GitHub] kafka pull request: KAFKA-3242: minor rename / logging change to C...

GitHub user benstopford opened a pull request: https://github.com/apache/kafka/pull/924 KAFKA-3242: minor rename / logging change to Controller KAFKA-3242: minor rename / logging change to references to 'adding partitions' to indicate 'modifying partitions' You can merge this pull

[jira] [Commented] (KAFKA-3243) Fix Kafka basic ops documentation for Mirror maker, blacklist is not supported for new consumers

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

[jira] [Updated] (KAFKA-3243) Fix Kafka basic ops documentation for Mirror maker, blacklist is not supported for new consumers

[ https://issues.apache.org/jira/browse/KAFKA-3243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3243: -- Status: Patch Available (was: Open) > Fix Kafka basic ops documentation for Mirror maker,

[GitHub] kafka pull request: KAFKA-3243: Fix Kafka basic ops documentation ...

GitHub user SinghAsDev opened a pull request: https://github.com/apache/kafka/pull/923 KAFKA-3243: Fix Kafka basic ops documentation for Mirror maker, black… …list is not supported for new consumers You can merge this pull request into a Git repository by running: $ git

[jira] [Created] (KAFKA-3243) Fix Kafka basic ops documentation for Mirror maker, blacklist is not supported for new consumers

Ashish K Singh created KAFKA-3243: - Summary: Fix Kafka basic ops documentation for Mirror maker, blacklist is not supported for new consumers Key: KAFKA-3243 URL: https://issues.apache.org/jira/browse/KAFKA-3243

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

[ https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3007 started by Jason Gustafson. -- > Implement max.poll.records for new consumer (KIP-41) >

[jira] [Created] (KAFKA-3242) "Add Partition" log message doesn't actually indicate adding a partition

Gwen Shapira created KAFKA-3242: --- Summary: "Add Partition" log message doesn't actually indicate adding a partition Key: KAFKA-3242 URL: https://issues.apache.org/jira/browse/KAFKA-3242 Project: Kafka

Re: [DISCUSS] KIP-47 - Add timestamp-based log deletion policy

Bill, Thanks for the proposal. A couple of comments. 1. It seems that this new policy should work for CreateTime as well. If a topic is configured with CreateTime, messages may not be added in strict order in the log. However, to build a time-based index, we will be maintaining the largest

[jira] [Comment Edited] (KAFKA-3238) Deadlock Mirrormaker consumer not fetching any messages

[ https://issues.apache.org/jira/browse/KAFKA-3238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15149068#comment-15149068 ] Rekha Joshi edited comment on KAFKA-3238 at 2/16/16 9:29 PM: - anyone home? :)

[jira] [Created] (KAFKA-3241) JmxReporter produces invalid JSON when a value is Infinity

Babak Behzad created KAFKA-3241: --- Summary: JmxReporter produces invalid JSON when a value is Infinity Key: KAFKA-3241 URL: https://issues.apache.org/jira/browse/KAFKA-3241 Project: Kafka Issue

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

See Changes: [me] MINOR: Reconcile differences in .bat & .sh start scripts -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-us1 (docker

[GitHub] kafka pull request: MINOR: Reconcile differences in .bat & .sh sta...

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

[jira] [Closed] (KAFKA-3088) 0.9.0.0 broker crash on receipt of produce request with empty client ID

[ https://issues.apache.org/jira/browse/KAFKA-3088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy closed KAFKA-3088. - Thanks for the patches - this has been pushed to trunk and 0.9 > 0.9.0.0 broker crash on receipt of produce

[jira] [Updated] (KAFKA-3088) 0.9.0.0 broker crash on receipt of produce request with empty client ID

[ https://issues.apache.org/jira/browse/KAFKA-3088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3088: --- Resolution: Fixed Status: Resolved (was: Patch Available) > 0.9.0.0 broker crash on receipt

[jira] [Commented] (KAFKA-3088) 0.9.0.0 broker crash on receipt of produce request with empty client ID

[ https://issues.apache.org/jira/browse/KAFKA-3088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15149175#comment-15149175 ] ASF GitHub Bot commented on KAFKA-3088: --- Github user granthenke closed the pull request at:

[GitHub] kafka pull request: KAFKA-3088: (0.9 branch) broker crash on recei...

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

[jira] [Commented] (KAFKA-3238) Deadlock Mirrormaker consumer not fetching any messages

[ https://issues.apache.org/jira/browse/KAFKA-3238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15149068#comment-15149068 ] Rekha Joshi commented on KAFKA-3238: anyone home? :) would be great to have your inputs! thanks

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

See Changes: [me] KAFKA-3227; Conservative update of Kafka dependencies -- [...truncated 4162 lines...] org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest >

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

See Changes: [me] KAFKA-3227; Conservative update of Kafka dependencies -- [...truncated 4850 lines...] org.apache.kafka.connect.runtime.rest.resources.ConnectorsResourceTest >

[jira] [Updated] (KAFKA-3176) Allow console consumer to consume from particular partitions when new consumer is used.

[ https://issues.apache.org/jira/browse/KAFKA-3176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-3176: --- Status: Patch Available (was: Open) > Allow console consumer to consume from particular

Re: [DISCUSS] KIP-46: Self Healing

Thanks Neha. I'll discard this for now. We can pick it up once replica throttling and the default policies are available and tested. On Thu, Feb 11, 2016 at 5:45 PM, Neha Narkhede wrote: > > > > 1. Replica Throttling - I agree this is rather important to get done. > >

[jira] [Commented] (KAFKA-3176) Allow console consumer to consume from particular partitions when new consumer is used.

[ https://issues.apache.org/jira/browse/KAFKA-3176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148787#comment-15148787 ] ASF GitHub Bot commented on KAFKA-3176: --- Github user vahidhashemian closed the pull request at:

[GitHub] kafka pull request: KAFKA-3176: Add partition/offset options to bo...

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

[jira] [Resolved] (KAFKA-3227) Conservative update of Kafka dependencies

[ https://issues.apache.org/jira/browse/KAFKA-3227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3227. -- Resolution: Fixed Issue resolved by pull request 903

[jira] [Commented] (KAFKA-3227) Conservative update of Kafka dependencies

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

[GitHub] kafka pull request: KAFKA-3227; Conservative update of Kafka depen...

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

[jira] [Commented] (KAFKA-3176) Allow console consumer to consume from particular partitions when new consumer is used.

[ https://issues.apache.org/jira/browse/KAFKA-3176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148788#comment-15148788 ] ASF GitHub Bot commented on KAFKA-3176: --- GitHub user vahidhashemian reopened a pull request:

[GitHub] kafka pull request: KAFKA-3176: Add partition/offset options to bo...

GitHub user vahidhashemian reopened a pull request: https://github.com/apache/kafka/pull/922 KAFKA-3176: Add partition/offset options to both old and new console consumers With this pull request both old and new console consumers can be provided with optional --partition and

[jira] [Assigned] (KAFKA-2273) Add rebalance with a minimal number of reassignments to server-defined strategy list

[ https://issues.apache.org/jira/browse/KAFKA-2273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-2273: -- Assignee: Vahid Hashemian > Add rebalance with a minimal number of reassignments to

[jira] [Commented] (KAFKA-3176) Allow console consumer to consume from particular partitions when new consumer is used.

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

[GitHub] kafka pull request: KAFKA-3176: Add partition/offset options to bo...

GitHub user vahidhashemian opened a pull request: https://github.com/apache/kafka/pull/922 KAFKA-3176: Add partition/offset options to both old and new console consumers With this pull request both old and new console consumers can be provided with optional --partition and

[jira] [Commented] (KAFKA-3240) Replication issues on FreeBSD

[ https://issues.apache.org/jira/browse/KAFKA-3240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148529#comment-15148529 ] Jan Omar commented on KAFKA-3240: - Using UFS instead of ZFS works. But we'd really like to use ZFS

[jira] [Updated] (KAFKA-3239) Timing issue in controller metrics on topic delete

[ https://issues.apache.org/jira/browse/KAFKA-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-3239: -- Resolution: Cannot Reproduce Fix Version/s: (was: 0.9.1.0) Status:

[jira] [Created] (KAFKA-3240) Replication issues on FreeBSD

Jan Omar created KAFKA-3240: --- Summary: Replication issues on FreeBSD Key: KAFKA-3240 URL: https://issues.apache.org/jira/browse/KAFKA-3240 Project: Kafka Issue Type: Bug Components: core

[jira] [Commented] (KAFKA-3239) Timing issue in controller metrics on topic delete

[ https://issues.apache.org/jira/browse/KAFKA-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148357#comment-15148357 ] Rajini Sivaram commented on KAFKA-3239: --- [~ijuma] Yes, you are absolutely right. I will close the

[GitHub] kafka pull request: KAFKA-3239: Synchronize removeTopic using cont...

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

[jira] [Commented] (KAFKA-3239) Timing issue in controller metrics on topic delete

[ https://issues.apache.org/jira/browse/KAFKA-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148358#comment-15148358 ] ASF GitHub Bot commented on KAFKA-3239: --- Github user rajinisivaram closed the pull request at:

[jira] [Commented] (KAFKA-3239) Timing issue in controller metrics on topic delete

[ https://issues.apache.org/jira/browse/KAFKA-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148291#comment-15148291 ] Ismael Juma commented on KAFKA-3239: The methods in `ControllerContext` are not thread-safe in

[jira] [Commented] (KAFKA-3239) Timing issue in controller metrics on topic delete

[ https://issues.apache.org/jira/browse/KAFKA-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148288#comment-15148288 ] Ismael Juma commented on KAFKA-3239: [~rsivaram], the only usage of `removeTopic` in the Kafka

[jira] [Updated] (KAFKA-3239) Timing issue in controller metrics on topic delete

[ https://issues.apache.org/jira/browse/KAFKA-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3239: --- Fix Version/s: 0.9.1.0 > Timing issue in controller metrics on topic delete >

[jira] [Updated] (KAFKA-3239) Timing issue in controller metrics on topic delete

[ https://issues.apache.org/jira/browse/KAFKA-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-3239: -- Status: Patch Available (was: Open) > Timing issue in controller metrics on topic delete >

[jira] [Commented] (KAFKA-3239) Timing issue in controller metrics on topic delete

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

[GitHub] kafka pull request: KAFKA-3239: Synchronize removeTopic using cont...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/921 KAFKA-3239: Synchronize removeTopic using controllerLock You can merge this pull request into a Git repository by running: $ git pull https://github.com/rajinisivaram/kafka KAFKA-3239

[jira] [Created] (KAFKA-3239) Timing issue in controller metrics on topic delete

Rajini Sivaram created KAFKA-3239: - Summary: Timing issue in controller metrics on topic delete Key: KAFKA-3239 URL: https://issues.apache.org/jira/browse/KAFKA-3239 Project: Kafka Issue