[jira] [Commented] (KAFKA-3237) ConfigDef validators require a default value

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

[GitHub] kafka pull request: KAFKA-3237 - Remove test cases testInvalidDefa...

GitHub user jcustenborder opened a pull request: https://github.com/apache/kafka/pull/936 KAFKA-3237 - Remove test cases testInvalidDefaultRange() and testInva… Remove test cases testInvalidDefaultRange() and testInvalidDefaultString(). Defaults if not overridden will get checked

[GitHub] kafka pull request: MINOR - remove unused imports in package kafka...

GitHub user zhuchen1018 opened a pull request: https://github.com/apache/kafka/pull/935 MINOR - remove unused imports in package kafka.utils You can merge this pull request into a Git repository by running: $ git pull https://github.com/zhuchen1018/kafka

[jira] [Updated] (KAFKA-1215) Rack-Aware replica assignment option

[ https://issues.apache.org/jira/browse/KAFKA-1215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1215: --- Assignee: Allen Wang (was: Jun Rao) > Rack-Aware replica assignment option >

[jira] [Commented] (KAFKA-3250) release tarball is unnecessarily large due to duplicate libraries

[ https://issues.apache.org/jira/browse/KAFKA-3250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15153398#comment-15153398 ] Ismael Juma commented on KAFKA-3250: Oh well. I'll check why when I test that PR. > release tarball

[jira] [Commented] (KAFKA-3250) release tarball is unnecessarily large due to duplicate libraries

[ https://issues.apache.org/jira/browse/KAFKA-3250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15153395#comment-15153395 ] Gwen Shapira commented on KAFKA-3250: - It does not. {code} Chens-MacBook-Pro:distributions gwen$ ls

[jira] [Commented] (KAFKA-3250) release tarball is unnecessarily large due to duplicate libraries

[ https://issues.apache.org/jira/browse/KAFKA-3250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15153383#comment-15153383 ] Ismael Juma commented on KAFKA-3250: https://github.com/apache/kafka/pull/693 may fix it. > release

[jira] [Created] (KAFKA-3250) release tarball is unnecessarily large due to duplicate libraries

Gwen Shapira created KAFKA-3250: --- Summary: release tarball is unnecessarily large due to duplicate libraries Key: KAFKA-3250 URL: https://issues.apache.org/jira/browse/KAFKA-3250 Project: Kafka

[jira] [Assigned] (KAFKA-3201) Add system test for KIP-31 and KIP-32 - Upgrade Test

[ https://issues.apache.org/jira/browse/KAFKA-3201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner reassigned KAFKA-3201: --- Assignee: Anna Povzner > Add system test for KIP-31 and KIP-32 - Upgrade Test >

[jira] [Commented] (KAFKA-3201) Add system test for KIP-31 and KIP-32 - Upgrade Test

[ https://issues.apache.org/jira/browse/KAFKA-3201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15153249#comment-15153249 ] Anna Povzner commented on KAFKA-3201: - Actually, it makes more sense to do this one before the

How to move a broker to a new host/ip

Hi! If I change the host.name, or the port properties of a broker, what's the easiest way to get Zookeeper to pick up the changes. Note that that no data is being moved, just the configurations of the broker changes to use a different port, network interface or DNS address. Cheers, Eugene

[jira] [Updated] (KAFKA-3249) Consider implementing a blocking admin requests after the initial KIP-4 work is done

[ https://issues.apache.org/jira/browse/KAFKA-3249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3249: --- Description: We have decided to make all requests/responses asynchronous in KIP-4 but see value in

[jira] [Created] (KAFKA-3249) Consider implementing a blocking admin requests after the initial KIP-4 work is done

Grant Henke created KAFKA-3249: -- Summary: Consider implementing a blocking admin requests after the initial KIP-4 work is done Key: KAFKA-3249 URL: https://issues.apache.org/jira/browse/KAFKA-3249

[GitHub] kafka pull request: KAFKA-3236: Honor Producer Configuration "bloc...

GitHub user knusbaum opened a pull request: https://github.com/apache/kafka/pull/934 KAFKA-3236: Honor Producer Configuration "block.on.buffer.full" You can merge this pull request into a Git repository by running: $ git pull https://github.com/knusbaum/kafka

[jira] [Commented] (KAFKA-3236) Honor Producer Configuration "block.on.buffer.full"

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

[GitHub] kafka pull request: MINOR: catch a commit failure due to rebalance

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/933 MINOR: catch a commit failure due to rebalance StreamThread should keep going after a commit was failed due to a group rebalance. Currently the thread just dies. @guozhangwang You can

Re: request to become contributor

Done - and I left a comment on that ticket as well. On Thu, Feb 18, 2016 at 11:32 AM, Dustin Cote wrote: > Hi folks, > > I wanted to take a crack at implementing KAFKA-2670 > . I think it's a fairly > straightforward

[jira] [Commented] (KAFKA-2670) add sampling rate to MirrorMaker

[ https://issues.apache.org/jira/browse/KAFKA-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15153180#comment-15153180 ] Joel Koshy commented on KAFKA-2670: --- It should be possible to accomplish this with a custom [consumer

When to use advertised.host.name ?

The FAQ says: "When a broker starts up, it registers its ip/port in ZK. You need to make sure the registered ip is consistent with what's listed in metadata.broker.list in the producer config. By default, the registered ip is given by InetAddress.getLocalHost.getHostAddress. Typically, this

[jira] [Created] (KAFKA-3248) AdminClient Blocks Forever in send Method

John Tylwalk created KAFKA-3248: --- Summary: AdminClient Blocks Forever in send Method Key: KAFKA-3248 URL: https://issues.apache.org/jira/browse/KAFKA-3248 Project: Kafka Issue Type: Bug

request to become contributor

Hi folks, I wanted to take a crack at implementing KAFKA-2670 . I think it's a fairly straightforward implementation. Can I be added as a contributor so I can get the process started of assigning it to myself and getting a pull request going?

[jira] [Commented] (KAFKA-3247) kafka-topic tool can use an option to see just "unbalanced partitions"

[ https://issues.apache.org/jira/browse/KAFKA-3247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15152976#comment-15152976 ] Ashish K Singh commented on KAFKA-3247: --- [~gwenshap] sounds useful. Mind if I take a stab at it. >

[jira] [Created] (KAFKA-3247) kafka-topic tool can use an option to see just "unbalanced partitions"

Gwen Shapira created KAFKA-3247: --- Summary: kafka-topic tool can use an option to see just "unbalanced partitions" Key: KAFKA-3247 URL: https://issues.apache.org/jira/browse/KAFKA-3247 Project: Kafka

[jira] [Commented] (KAFKA-3221) kafka-acls.sh must verify if a user has sufficient privileges to perform acls CRUD

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

[GitHub] kafka pull request: KAFKA-3221: Pass requesting user information t...

Github user SinghAsDev closed the pull request at: https://github.com/apache/kafka/pull/895 --- 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-2832) support exclude.internal.topics in new consumer

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

[jira] [Commented] (KAFKA-3236) Honor Producer Configuration "block.on.buffer.full"

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

[GitHub] kafka pull request: KAFKA-2832: Add a consumer config option to ex...

GitHub user vahidhashemian opened a pull request: https://github.com/apache/kafka/pull/932 KAFKA-2832: Add a consumer config option to exclude internal topics A new consumer config option 'exclude.internal.topics' was added to allow excluding internal topics when wildcards are used

[GitHub] kafka pull request: KAFKA-3236: Honor Producer Configuration "bloc...

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

Re: [POLL] Make next Kafka Release 0.10.0.0 instead of 0.9.1.0

+1 Tom On Tuesday, February 9, 2016 12:08 PM, Becket Qin wrote: Hi All, Next Kafka release will have several significant important new feature/changes such as Kafka Stream, Message Format Change, Client Interceptors and several new consumer API changes, etc. We

[jira] [Assigned] (KAFKA-2832) support exclude.internal.topics in new consumer

[ https://issues.apache.org/jira/browse/KAFKA-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-2832: -- Assignee: Vahid Hashemian > support exclude.internal.topics in new consumer >

Re: [POLL] Make next Kafka Release 0.10.0.0 instead of 0.9.1.0

Hi Becket, Did you mean this to be an official [VOTE] thread? If so, it may be a good idea to start a new thread with the appropriate title and link to this one. It would be good to agree on this relatively soon so that we can update JIRA, the wiki and anywhere in the code and documentation where

[jira] [Updated] (KAFKA-2936) Socket server selector can stuck on one send in tight loop.

[ https://issues.apache.org/jira/browse/KAFKA-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2936: --- Fix Version/s: (was: 0.9.0.1) > Socket server selector can stuck on one send in tight loop. >

[jira] [Updated] (KAFKA-2878) Kafka broker throws OutOfMemory exception with invalid join group request

[ https://issues.apache.org/jira/browse/KAFKA-2878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2878: --- Fix Version/s: 0.9.0.1 > Kafka broker throws OutOfMemory exception with invalid join group request >

[jira] [Updated] (KAFKA-2655) Consumer.poll(0)'s overhead too large

[ https://issues.apache.org/jira/browse/KAFKA-2655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2655: --- Fix Version/s: (was: 0.9.0.1) > Consumer.poll(0)'s overhead too large >