[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 dynami

[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&focusedCommentId=15097796#comment-15097796 ] ASF GitHub Bot commented on KAFKA-3080: --- GitHub user ewencp opened a pull request:

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

Ismael Juma created KAFKA-3105: -- Summary: Use `Utils.atomicMoveWithFallback` instead of `File.rename` Key: KAFKA-3105 URL: https://issues.apache.org/jira/browse/KAFKA-3105 Project: Kafka Issue

[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: --- Description: It behaves better on Windows and provides more useful error messages. (was: It behaves b

[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 `kafka.serve

[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&focusedCommentId=15097841#comment-15097841 ] ASF GitHub Bot commented on KAFKA-3105: --- GitHub user ijuma opened a pull request:

[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&focusedCommentId=15097844#comment-15097844 ] ASF GitHub Bot commented on KAFKA-3087: --- GitHub user rajubairishetti opened a pull r

[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 |Default|

[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] [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 ass

[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` > -

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: > > > Hi All, > > > > I'd like to open up the vo

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 gives users a way to >

[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&focusedCommentId=15097948#comment-15097948 ] Jens Rantil commented on KAFKA-3094: Also, are you seeing anything specific in the Kaf

[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&focusedCommentId=15097946#comment-15097946 ] Jens Rantil commented on KAFKA-3094: Omar: Can you recreate this issue? If so, would i

[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&focusedCommentId=15097951#comment-15097951 ] jin xing commented on KAFKA-3106: - [~ewencp] Is is appropriate to call a rebalance by "me

[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 ass

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

[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 https://github.com/ijuma/kafk

[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 json

[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&focusedCommentId=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&focusedCommentId=15098314#comment-15098314 ] Ismael Juma commented on KAFKA-3100: After some thought, it makes more sense to update

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 ZkUtils.getBrokerInfo(), ol

[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: Ka

[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&focusedCommentId=15098458#comment-15098458 ] Ewen Cheslack-Postava commented on KAFKA-3106: -- Rebalances are going to be pr

[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&focusedCommentId=15098512#comment-15098512 ] Mohit Anchlia commented on KAFKA-3102: -- I enabled debug and still not much info: [20

[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&focusedCommentId=15098512#comment-15098512 ] Mohit Anchlia edited comment on KAFKA-3102 at 1/14/16 5:54 PM: -

[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: S

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

[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] [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" app

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 "max.poll.records" which sets an upper bound on the > >

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

[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&focusedCommentId=15098607#comment-15098607 ] Mayuresh Gharat commented on KAFKA-3083: That's a very good point, I will verify i

[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&focusedCommentId=15098607#comment-15098607 ] Mayuresh Gharat edited comment on KAFKA-3083 at 1/14/16 6:34 PM: ---

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 > > procedure of upgrade. > > > Thanks All

[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 Alternatively

[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 did

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

[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 yo

[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&focusedCommentId=15098883#comment-15098883 ] ASF GitHub Bot commented on KAFKA-3050: --- GitHub user Zixxy opened a pull request:

[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 Partitioner

[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 ```WindowedStreamPart

[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&focusedCommentId=15099106#comment-15099106 ] ASF GitHub Bot commented on KAFKA-3108: --- GitHub user ymatsuda opened a pull request:

[GitHub] kafka pull request: MINOR: Improve Kafka documentation

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

GitHub user vahidhashemian reopened 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] [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&focusedCommentId=15099141#comment-15099141 ] Jason Gustafson commented on KAFKA-2695: After looking at this, I feel uneasy abou

[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&focusedCommentId=15098512#comment-15098512 ] Mohit Anchlia edited comment on KAFKA-3102 at 1/15/16 12:00 AM:

[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&focusedCommentId=15098512#comment-15098512 ] Mohit Anchlia edited comment on KAFKA-3102 at 1/15/16 12:38 AM:

[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&focusedCommentId=15098512#comment-15098512 ] Mohit Anchlia edited comment on KAFKA-3102 at 1/15/16 12:46 AM:

[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

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

[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 enabl

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 wor

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

[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 enabl

[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 [https://gith

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 envir

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 kafka.log.Bro