[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=15098250#comment-15098250 ] Jun Rao commented on KAFKA-2695: [~hachikuji], when using a compacted topic, we use a null value in the

[GitHub] kafka pull request: KAFKA-3100; Broker.createBroker should work if...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/773 KAFKA-3100; Broker.createBroker should work if json is version > 2 and still compatible You can merge this pull request into a Git repository by running: $ git pull

[jira] [Updated] (KAFKA-3100) Broker.createBroker should work if json is version > 2, but still compatible

[ https://issues.apache.org/jira/browse/KAFKA-3100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3100: --- Reviewer: Jun Rao Status: Patch Available (was: Open) > Broker.createBroker should work if

[jira] [Commented] (KAFKA-3100) Broker.createBroker should work if json is version > 2, but still compatible

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

[jira] [Commented] (KAFKA-3100) Broker.createBroker should work if json is version > 2, but still compatible

[ https://issues.apache.org/jira/browse/KAFKA-3100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15098314#comment-15098314 ] Ismael Juma commented on KAFKA-3100: After some thought, it makes more sense to update the upgrade

[jira] [Updated] (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:all-tabpanel ] Ismael Juma updated KAFKA-1464: --- Fix Version/s: 0.9.1.0 > Add a throttling option to the Kafka replication tool >

[jira] [Commented] (KAFKA-3102) Kafka server unable to connect to zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15098512#comment-15098512 ] Mohit Anchlia commented on KAFKA-3102: -- I enabled debug and still not much info: [2016-01-14

[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 ] David Jacot updated KAFKA-3098: --- Assignee: David Jacot Status: Patch Available (was: Open) > "partition.assignment.strategy"

[jira] [Commented] (KAFKA-3106) After PUT a connector config from REST API, GET a connector config will fail

[ https://issues.apache.org/jira/browse/KAFKA-3106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15098458#comment-15098458 ] Ewen Cheslack-Postava commented on KAFKA-3106: -- Rebalances are going to be pretty expensive

[jira] [Comment Edited] (KAFKA-3102) Kafka server unable to connect to zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15098512#comment-15098512 ] Mohit Anchlia edited comment on KAFKA-3102 at 1/14/16 5:54 PM: --- I enabled

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

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

GitHub user dajac opened a pull request: https://github.com/apache/kafka/pull/774 KAFKA-3098: "partition.assignment.strategy" appears twice in documentation You can merge this pull request into a Git repository by running: $ git pull https://github.com/dajac/kafka KAFKA-3098

[jira] [Assigned] (KAFKA-3050) Space in the value for "host.name" causes "Unresolved address"

[ https://issues.apache.org/jira/browse/KAFKA-3050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sylwester reassigned KAFKA-3050: Assignee: Sylwester > Space in the value for "host.name" causes "Unresolved address" >

[jira] [Created] (KAFKA-3108) KStream custom Partitioner for windowed key

Yasuhiro Matsuda created KAFKA-3108: --- Summary: KStream custom Partitioner for windowed key Key: KAFKA-3108 URL: https://issues.apache.org/jira/browse/KAFKA-3108 Project: Kafka Issue Type:

[GitHub] kafka pull request: KAFKA-3080: Fix ConsoleConsumerTest by checkin...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/770 KAFKA-3080: Fix ConsoleConsumerTest by checking version when service is started The MessageFormatter being used was only introduced as of 0.9.0.0. The Kafka version in some tests is changed

[jira] [Commented] (KAFKA-3080) ConsoleConsumerTest.test_version system test fails consistently

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

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

+1 (non-binding) On Thu, Jan 14, 2016 at 6:26 AM, Neha Narkhede wrote: > +1 (binding) > > > > > > > On Wed, Jan 13, 2016 at 9:10 PM -0800, "Joel Koshy" > wrote: > > > > > > > > > > > +1 > > On Wed, Jan 13, 2016 at 3:18 PM, Jason Gustafson wrote: > > >

[jira] [Updated] (KAFKA-3106) After PUT a connector config from REST API, GET a connector config will fail

[ https://issues.apache.org/jira/browse/KAFKA-3106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jin xing updated KAFKA-3106: Description: If there is already a connector in Connect, and we PUT a connector config by REST API, the

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

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

[jira] [Commented] (KAFKA-3094) Kafka process 100% CPU when no message in topic

[ https://issues.apache.org/jira/browse/KAFKA-3094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15097948#comment-15097948 ] Jens Rantil commented on KAFKA-3094: Also, are you seeing anything specific in the Kafka logs? >

[jira] [Commented] (KAFKA-3094) Kafka process 100% CPU when no message in topic

[ https://issues.apache.org/jira/browse/KAFKA-3094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15097946#comment-15097946 ] Jens Rantil commented on KAFKA-3094: Omar: Can you recreate this issue? If so, would it be possible

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

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/771 KAFKA-3105: Use `Utils.atomicMoveWithFallback` instead of `File.rename` It behaves better on Windows and provides more useful error messages. Also: * Minor inconsistency fix in

[jira] [Commented] (KAFKA-3106) After PUT a connector config from REST API, GET a connector config will fail

[ https://issues.apache.org/jira/browse/KAFKA-3106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15097951#comment-15097951 ] jin xing commented on KAFKA-3106: - [~ewencp] Is is appropriate to call a rebalance by

[jira] [Updated] (KAFKA-3106) After PUT a connector config from REST API, GET a connector config will fail

[ https://issues.apache.org/jira/browse/KAFKA-3106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jin xing updated KAFKA-3106: Description: If there is already a connector in Connect, and we PUT a connector config by REST API, the

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

+1 On Thu, Jan 14, 2016 at 12:18 AM, 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 returned in a call to poll(). This

[GitHub] kafka pull request: KAFKA-3087: Fix retention.ms property document...

GitHub user rajubairishetti opened a pull request: https://github.com/apache/kafka/pull/772 KAFKA-3087: Fix retention.ms property documentation in config docs Log retention settings can be set it in broker and some properties can be overriden at topic level. |Property

[jira] [Created] (KAFKA-3106) After PUT a connector config from REST API, GET a connector config will fail

jin xing created KAFKA-3106: --- Summary: After PUT a connector config from REST API, GET a connector config will fail Key: KAFKA-3106 URL: https://issues.apache.org/jira/browse/KAFKA-3106 Project: Kafka

[jira] [Commented] (KAFKA-3087) Fix documentation for retention.ms property and update documentation for LogConfig.scala class

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

[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 ] Ismael Juma updated KAFKA-3105: --- Status: Patch Available (was: Open) > Use `Utils.atomicMoveWithFallback` instead of `File.rename` >

[jira] [Created] (KAFKA-3107) Error when trying to shut down auto balancing scheduler of controller

Flavio Junqueira created KAFKA-3107: --- Summary: Error when trying to shut down auto balancing scheduler of controller Key: KAFKA-3107 URL: https://issues.apache.org/jira/browse/KAFKA-3107 Project:

[jira] [Commented] (KAFKA-3108) KStream custom StreamPartitioner for windowed key

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

[GitHub] kafka pull request: KAFKA-3108: custom StreamParitioner for Window...

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/779 KAFKA-3108: custom StreamParitioner for Windowed key @guozhangwang When ```WindowedSerializer``` is specified in ```to(...)``` or ```through(...)``` for a key, we use

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

See Changes: [wangguoz] MINOR: add internal source topic for tracking [wangguoz] KAFKA-3108: custom StreamParitioner for Windowed key -- Started by an SCM change [EnvInject] - Loading node

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

See Changes: [wangguoz] KAFKA-3108: custom StreamParitioner for Windowed key -- [...truncated 2797 lines...] kafka.log.BrokerCompressionTest > testBrokerSideCompression[17] PASSED

[jira] [Resolved] (KAFKA-3108) KStream custom StreamPartitioner for windowed key

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

[jira] [Commented] (KAFKA-3108) KStream custom StreamPartitioner for windowed key

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

[GitHub] kafka pull request: KAFKA-3108: custom StreamParitioner for Window...

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

GitHub user vahidhashemian opened a pull request: https://github.com/apache/kafka/pull/778 MINOR: Improve Kafka documentation Improve the documentation by fixing typos, punctuations, and correcting the content. You can merge this pull request into a Git repository by running:

[jira] [Updated] (KAFKA-3108) KStream custom StreamPartitioner for windowed key

[ https://issues.apache.org/jira/browse/KAFKA-3108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yasuhiro Matsuda updated KAFKA-3108: Priority: Minor (was: Major) > KStream custom StreamPartitioner for windowed key >

[jira] [Updated] (KAFKA-3108) KStream custom StreamPartitioner for windowed key

[ https://issues.apache.org/jira/browse/KAFKA-3108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yasuhiro Matsuda updated KAFKA-3108: Summary: KStream custom StreamPartitioner for windowed key (was: KStream custom

[jira] [Comment Edited] (KAFKA-3102) Kafka server unable to connect to zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15098512#comment-15098512 ] Mohit Anchlia edited comment on KAFKA-3102 at 1/15/16 12:38 AM: I enabled

[GitHub] kafka pull request: MINOR: add internal source topic for tracking

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

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

See Changes: [wangguoz] MINOR: add internal source topic for tracking -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (Ubuntu ubuntu) in

[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=15098604#comment-15098604 ] Jason Gustafson commented on KAFKA-2695: [~junrao] That actually works currently because records

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

[ https://issues.apache.org/jira/browse/KAFKA-3083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15098607#comment-15098607 ] Mayuresh Gharat commented on KAFKA-3083: That's a very good point, I will verify if this can

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

Thanks Ismael. KIP is updated to use 0.9.0.0 and add link to the JIRA. On Thu, Jan 14, 2016 at 8:46 AM, Ismael Juma wrote: > On Thu, Jan 14, 2016 at 1:24 AM, Allen Wang wrote: > > > Updated KIP regarding how broker JSON version will be handled and new

[jira] [Comment Edited] (KAFKA-3102) Kafka server unable to connect to zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15098512#comment-15098512 ] Mohit Anchlia edited comment on KAFKA-3102 at 1/15/16 12:00 AM: I enabled

[jira] [Comment Edited] (KAFKA-3102) Kafka server unable to connect to zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15098512#comment-15098512 ] Mohit Anchlia edited comment on KAFKA-3102 at 1/15/16 12:46 AM: I enabled

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

[GitHub] kafka pull request: KAFKA-2695: limited support for nullable byte ...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/780 KAFKA-2695: limited support for nullable byte arrays You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-2695 Alternatively

[GitHub] kafka pull request: KAFKA-3050: Acceptor allows hostnames surround...

GitHub user Zixxy opened a pull request: https://github.com/apache/kafka/pull/777 KAFKA-3050: Acceptor allows hostnames surrounded by whitespaces You can merge this pull request into a Git repository by running: $ git pull https://github.com/Zixxy/kafka trunk Alternatively

[jira] [Commented] (KAFKA-3050) Space in the value for "host.name" causes "Unresolved address"

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

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

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

GitHub user tgravescs opened a pull request: https://github.com/apache/kafka/pull/776 KAFKA-3095: No documentation on format of sasl.kerberos.principal.to.local.rules Add some basic documentation about the format, a link to get more detailed information and an example usage. I

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

+1 On Thu, Jan 14, 2016 at 2:05 AM, Jens Rantil wrote: > +1 > > On Thu, Jan 14, 2016 at 12:18 AM, Jason Gustafson > wrote: > > > Hi All, > > > > I'd like to open up the vote on KIP-41. This KIP adds a new consumer > > configuration option

[GitHub] kafka pull request: MINOR: add internal source topic for tracking

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/775 MINOR: add internal source topic for tracking You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka KRepartTopic

[jira] [Comment Edited] (KAFKA-3083) a soft failure in controller may leader a topic partition in an inconsistent state

[ https://issues.apache.org/jira/browse/KAFKA-3083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15098607#comment-15098607 ] Mayuresh Gharat edited comment on KAFKA-3083 at 1/14/16 6:34 PM: - That's a

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

On Thu, Jan 14, 2016 at 1:24 AM, Allen Wang wrote: > Updated KIP regarding how broker JSON version will be handled and new > procedure of upgrade. Thanks Allen. In the following text, I think we should replace 0.9.0 with 0.9.0.0: "Due to a bug introduced in 0.9.0 in