[jira] [Commented] (KAFKA-2985) Consumer group stuck in rebalancing state

[ https://issues.apache.org/jira/browse/KAFKA-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105037#comment-15105037 ] Federico Fissore commented on KAFKA-2985: - I'm too experiencing the same behaviour. I have a short

[jira] [Comment Edited] (KAFKA-2985) Consumer group stuck in rebalancing state

[ https://issues.apache.org/jira/browse/KAFKA-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105037#comment-15105037 ] Federico Fissore edited comment on KAFKA-2985 at 1/18/16 10:00 AM: --- I'm

[jira] [Commented] (KAFKA-2985) Consumer group stuck in rebalancing state

[ https://issues.apache.org/jira/browse/KAFKA-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105078#comment-15105078 ] Federico Fissore commented on KAFKA-2985: - Below a snipped of the broker logs when running above

[jira] [Comment Edited] (KAFKA-2985) Consumer group stuck in rebalancing state

[ https://issues.apache.org/jira/browse/KAFKA-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105539#comment-15105539 ] Michal Turek edited comment on KAFKA-2985 at 1/18/16 5:19 PM: -- I'm probably

[jira] [Updated] (KAFKA-3105) Use `Utils.atomicMoveWithFallback` instead of `File.rename`

[ https://issues.apache.org/jira/browse/KAFKA-3105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3105: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved

[GitHub] kafka pull request: KAFKA-3105: Use `Utils.atomicMoveWithFallback`...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/771 --- 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: KAFKA-2695: limited support for nullable byte ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/780 --- 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-2695) Handle null string/bytes protocol primitives

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

[jira] [Updated] (KAFKA-3098) "partition.assignment.strategy" appears twice in documentation

[ https://issues.apache.org/jira/browse/KAFKA-3098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3098: Resolution: Fixed Fix Version/s: 0.9.1.0 0.9.0.1 Status:

[jira] [Updated] (KAFKA-3083) a soft failure in controller may leave a topic partition in an inconsistent state

[ https://issues.apache.org/jira/browse/KAFKA-3083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-3083: Summary: a soft failure in controller may leave a topic partition in an inconsistent state

[jira] [Resolved] (KAFKA-2695) Handle null string/bytes protocol primitives

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

[jira] [Commented] (KAFKA-3114) can't create as many partitions as brokers exists

[ https://issues.apache.org/jira/browse/KAFKA-3114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105588#comment-15105588 ] Lukas Schmitt commented on KAFKA-3114: -- The ticket can be closed or removed. I fixed it by not using

[GitHub] kafka pull request: KAFKA-3098: "partition.assignment.strategy" ap...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/774 --- 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-3083) a soft failure in controller may leave a topic partition in an inconsistent state

[ https://issues.apache.org/jira/browse/KAFKA-3083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105587#comment-15105587 ] Flavio Junqueira commented on KAFKA-3083: - [~junrao] bq. does controller A just resume from where

[jira] [Commented] (KAFKA-3098) "partition.assignment.strategy" appears twice in documentation

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

[jira] [Resolved] (KAFKA-3114) can't create as many partitions as brokers exists

[ https://issues.apache.org/jira/browse/KAFKA-3114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-3114. - Resolution: Not A Problem Thanks for updating us. > can't create as many partitions as brokers

[jira] [Commented] (KAFKA-3083) a soft failure in controller may leave a topic partition in an inconsistent state

[ https://issues.apache.org/jira/browse/KAFKA-3083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105597#comment-15105597 ] Flavio Junqueira commented on KAFKA-3083: - [~junrao] bq. Even if it exists, it has the same

[GitHub] kafka pull request: KAFKA-3095: No documentation on format of sasl...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/776 --- 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-3095) No documentation on format of sasl.kerberos.principal.to.local.rules

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

[jira] [Commented] (KAFKA-2999) Errors enum should be a 1 to 1 mapping of error codes and exceptions

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

[GitHub] kafka pull request: KAFKA-2999: Errors enum should be a 1 to 1 map...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/766 --- 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] [Updated] (KAFKA-2999) Errors enum should be a 1 to 1 mapping of error codes and exceptions

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

[GitHub] kafka pull request: MINOR: MemoryRecords.sizeInBytes throws NPE wh...

GitHub user dajac opened a pull request: https://github.com/apache/kafka/pull/786 MINOR: MemoryRecords.sizeInBytes throws NPE when non-writable. I just noticed that `MemoryRecords.sizeInBytes` throws NPE when MemoryRecords is non-writable. `compressor` is explicitly set to null

[jira] [Updated] (KAFKA-3116) Failure to build

[ https://issues.apache.org/jira/browse/KAFKA-3116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] edwardt updated KAFKA-3116: --- Description: failure to build, says ScalaPlugin not found for project client Failed at bootstrap cd

[jira] [Commented] (KAFKA-3083) a soft failure in controller may leave a topic partition in an inconsistent state

[ https://issues.apache.org/jira/browse/KAFKA-3083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105612#comment-15105612 ] Flavio Junqueira commented on KAFKA-3083: - [~mgharat] bq. I was just thinking if we can modify

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

See Changes: [me] KAFKA-3105: Use `Utils.atomicMoveWithFallback` instead of `File.rename` [wangguoz] KAFKA-2695: limited support for nullable byte arrays [cshapi] KAFKA-3098: "partition.assignment.strategy" appears twice in [cshapi]

[jira] [Updated] (KAFKA-3116) Failure to build

[ https://issues.apache.org/jira/browse/KAFKA-3116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] edwardt updated KAFKA-3116: --- Description: failure to build, says ScalaPlugin not found for project client Failed at bootstrap cd

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

See Changes: [me] KAFKA-3105: Use `Utils.atomicMoveWithFallback` instead of `File.rename` [wangguoz] KAFKA-2695: limited support for nullable byte arrays [cshapi] KAFKA-3098: "partition.assignment.strategy" appears twice in [cshapi]

[jira] [Commented] (KAFKA-1464) Add a throttling option to the Kafka replication tool

[ https://issues.apache.org/jira/browse/KAFKA-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105639#comment-15105639 ] Eno Thereska commented on KAFKA-1464: - An alternative to throttling background maintenance traffic is

[jira] [Work started] (KAFKA-3104) Windowed Stream Aggregation Implementation

[ https://issues.apache.org/jira/browse/KAFKA-3104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3104 started by Guozhang Wang. > Windowed Stream Aggregation Implementation >

[jira] [Commented] (KAFKA-3119) Adding -daemon option to zookeeper-server-start.sh USAGE

[ https://issues.apache.org/jira/browse/KAFKA-3119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15106125#comment-15106125 ] Atul Soman commented on KAFKA-3119: --- I am unable to assign this issue to me. Is it because i do not have

[jira] [Created] (KAFKA-3117) Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance

edwardt created KAFKA-3117: -- Summary: Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance Key: KAFKA-3117 URL: https://issues.apache.org/jira/browse/KAFKA-3117 Project: Kafka Issue

[GitHub] kafka pull request: KAFKA-3119: Adding -daemon option to zookeeper...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/785 --- 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-3111) java.lang.ArithmeticException: / by zero in ConsumerPerformance

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

[jira] [Commented] (KAFKA-3111) java.lang.ArithmeticException: / by zero in ConsumerPerformance

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

[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=15106023#comment-15106023 ] Parth Brahmbhatt commented on KAFKA-1696: - [~gwenshap] Are you still working on this? We have some

[GitHub] kafka pull request: KAFKA-3111: Fix ConsumerPerformance output for...

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

[GitHub] kafka pull request: KAFKA-3111: Fix ConsumerPerformance output for...

GitHub user vahidhashemian reopened a pull request: https://github.com/apache/kafka/pull/788 KAFKA-3111: Fix ConsumerPerformance output for zero interval lengths Interval lengths for ConsumerPerformance could sometime be calculated as zero. In such cases, when the bytes read or

[jira] [Commented] (KAFKA-3012) Avoid reserved.broker.max.id collisions on upgrade

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

Build failed in Jenkins: kafka_0.9.0_jdk7 #87

See Changes: [cshapi] KAFKA-3012: Avoid reserved.broker.max.id collisions on upgrade -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu3

[jira] [Commented] (KAFKA-3091) Broker with an invalid id would not start when its id is updated to a new valid one

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

[GitHub] kafka pull request: KAFKA-3091: Broker with an invalid id would no...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/763 --- 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] [Updated] (KAFKA-3012) Avoid reserved.broker.max.id collisions on upgrade

[ https://issues.apache.org/jira/browse/KAFKA-3012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3012: Resolution: Fixed Fix Version/s: 0.9.1.0 0.9.0.1 Status:

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

See Changes: [cshapi] KAFKA-3012: Avoid reserved.broker.max.id collisions on upgrade [cshapi] KAFKA-3091: Broker persists generated ID even when the ID can't be used -- Started by an SCM change

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

See Changes: [cshapi] KAFKA-3119: Adding -daemon option to zookeeper-server-start.sh USAGE, [cshapi] KAFKA-3012: Avoid reserved.broker.max.id collisions on upgrade [cshapi] KAFKA-3091: Broker persists generated ID even when the ID

[jira] [Updated] (KAFKA-2066) Replace FetchRequest / FetchResponse with their org.apache.kafka.common.requests equivalents

[ https://issues.apache.org/jira/browse/KAFKA-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2066: - Reviewer: Ismael Juma > Replace FetchRequest / FetchResponse with their >

[GitHub] kafka pull request: MINOR: MemoryRecords.sizeInBytes throws NPE wh...

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

See Changes: [wangguoz] MINOR: MemoryRecords.sizeInBytes throws NPE when non-writable. -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11

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

See Changes: [wangguoz] MINOR: MemoryRecords.sizeInBytes throws NPE when non-writable. -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11

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

See

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

+1 (binding) On Mon, Jan 18, 2016 at 2:43 PM, Onur Karaman wrote: > +1 (non-binding) > > On Mon, Jan 18, 2016 at 2:32 PM, Jun Rao wrote: > > > Allen, > > > > Thanks for updating the KIP wiki. +1 > > > > Could other people take a look at the

[jira] [Commented] (KAFKA-3083) a soft failure in controller may leave a topic partition in an inconsistent state

[ https://issues.apache.org/jira/browse/KAFKA-3083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105762#comment-15105762 ] Flavio Junqueira commented on KAFKA-3083: - Another thing to mention is that if ZkClient didn't

[GitHub] kafka pull request: KAFKA-3104: add windowed aggregation to KStrea...

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

See Changes: [wangguoz] KAFKA-3104: add windowed aggregation to KStream -- [...truncated 2771 lines...] kafka.server.OffsetCommitTest > testOffsetExpiration PASSED

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

See Changes: [wangguoz] MINOR: complete built-in stream aggregate functions -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (Ubuntu ubuntu)

[jira] [Commented] (KAFKA-3104) Windowed Stream Aggregation Implementation

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

[jira] [Resolved] (KAFKA-3104) Windowed Stream Aggregation Implementation

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

Re: [VOTE] KIP-41: Consumer Max Records

Thanks for the proposal. +1. Jun On Wed, Jan 13, 2016 at 3:18 PM, Jason Gustafson wrote: > Hi All, > > I'd like to open up the vote on KIP-41. This KIP adds a new consumer > configuration option "max.poll.records" which sets an upper bound on the > number of records

[GitHub] kafka pull request: MINOR: complete built-in stream aggregate func...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/787 --- 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-3111) java.lang.ArithmeticException: / by zero in ConsumerPerformance

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

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

See Changes: [wangguoz] MINOR: complete built-in stream aggregate functions -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (Ubuntu ubuntu)

[GitHub] kafka pull request: KAFKA-3111: Fix ConsumerPerformance output for...

GitHub user vahidhashemian opened a pull request: https://github.com/apache/kafka/pull/788 KAFKA-3111: Fix ConsumerPerformance output for zero interval lengths Interval lengths for ConsumerPerformance could sometime be calculated as zero. In such cases, when the bytes read or

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

Allen, Thanks for updating the KIP wiki. +1 Could other people take a look at the latest proposal and vote on it? Thanks, Jun On Mon, Jan 4, 2016 at 4:30 PM, Allen Wang wrote: > I would like to call for a vote for KIP-36 - Rack aware replica assignment. > > The latest

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

+1 (non-binding) On Mon, Jan 18, 2016 at 2:32 PM, Jun Rao wrote: > Allen, > > Thanks for updating the KIP wiki. +1 > > Could other people take a look at the latest proposal and vote on it? > > Thanks, > > Jun > > On Mon, Jan 4, 2016 at 4:30 PM, Allen Wang