[jira] [Commented] (KAFKA-2408) (new) system tests: ConsoleConsumerService occasionally fails to register consumed message

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

[GitHub] kafka pull request: KAFKA-2408 ConsoleConsumerService direct log o...

GitHub user granders opened a pull request: https://github.com/apache/kafka/pull/123 KAFKA-2408 ConsoleConsumerService direct log output to file You can merge this pull request into a Git repository by running: $ git pull https://github.com/confluentinc/kafka KAFKA-2408 Alter

[jira] [Commented] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661329#comment-14661329 ] Ashish K Singh commented on KAFKA-2413: --- I am not sure if posting patches to issues

[jira] [Commented] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661319#comment-14661319 ] Onur Karaman commented on KAFKA-2413: - Aand I just saw this. My bad. > New consum

[GitHub] kafka pull request: KAFKA-2413: fix ConsumerCoordinator updateCons...

GitHub user onurkaraman opened a pull request: https://github.com/apache/kafka/pull/122 KAFKA-2413: fix ConsumerCoordinator updateConsumer You can merge this pull request into a Git repository by running: $ git pull https://github.com/onurkaraman/kafka KAFKA-2413 Alternativel

[jira] [Commented] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661317#comment-14661317 ] ASF GitHub Bot commented on KAFKA-2413: --- GitHub user onurkaraman opened a pull reque

[jira] [Commented] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661294#comment-14661294 ] Ashish K Singh commented on KAFKA-2413: --- Hi [~onurkaraman], sorry for not explicitly

[jira] [Commented] (KAFKA-2415) Transient failure in LogRecoveryTest.testHWCheckpointWithFailuresMultipleLogSegments

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

[GitHub] kafka pull request: KAFKA-2415: Fix transient failure in LogRecove...

GitHub user becketqin opened a pull request: https://github.com/apache/kafka/pull/121 KAFKA-2415: Fix transient failure in LogRecoveryTest You can merge this pull request into a Git repository by running: $ git pull https://github.com/becketqin/kafka KAFKA-2415 Alternatively

[jira] [Commented] (KAFKA-1997) Refactor Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661253#comment-14661253 ] Jiangjie Qin commented on KAFKA-1997: - Oh... I forgot to do it when integrating the cl

[jira] [Commented] (KAFKA-1997) Refactor Mirror Maker

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

[GitHub] kafka pull request: KAFKA-1997: Follow-up patch, hardcode key/valu...

GitHub user becketqin opened a pull request: https://github.com/apache/kafka/pull/120 KAFKA-1997: Follow-up patch, hardcode key/value serializer in mirror maker to byte serializer. Hardcode the key/value serializer to ByteArraySerializer according to Jun’s comments. You can merg

[jira] [Created] (KAFKA-2415) Transient failure in LogRecoveryTest.testHWCheckpointWithFailuresMultipleLogSegments

Jiangjie Qin created KAFKA-2415: --- Summary: Transient failure in LogRecoveryTest.testHWCheckpointWithFailuresMultipleLogSegments Key: KAFKA-2415 URL: https://issues.apache.org/jira/browse/KAFKA-2415 Proj

[jira] [Commented] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661246#comment-14661246 ] Onur Karaman commented on KAFKA-2413: - I'll have the patch ready later today. > New c

[jira] [Commented] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661242#comment-14661242 ] Onur Karaman commented on KAFKA-2413: - Okay I just tested it out. It seems to have fix

[jira] [Comment Edited] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661227#comment-14661227 ] Onur Karaman edited comment on KAFKA-2413 at 8/7/15 2:51 AM: -

[jira] [Comment Edited] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661227#comment-14661227 ] Onur Karaman edited comment on KAFKA-2413 at 8/7/15 2:51 AM: -

[jira] [Commented] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661227#comment-14661227 ] Onur Karaman commented on KAFKA-2413: - Woops! I haven't tried it out yet, but I think

[jira] [Commented] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661177#comment-14661177 ] Ashish K Singh commented on KAFKA-2413: --- [~hachikuji] I was planning to play with it

[jira] [Commented] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661167#comment-14661167 ] Jason Gustafson commented on KAFKA-2413: [~singhashish] I can attempt a patch if y

[jira] [Updated] (KAFKA-2414) Running kafka-producer-perf-test.sh with " --messages 10000000 --message-size 1000 --new-producer" will get WARN Error in I/O.

[ https://issues.apache.org/jira/browse/KAFKA-2414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2414: --- Description: Running kafka-producer-perf-test.sh with " --messages 1000 --message-size 1000 --new-produ

[jira] [Updated] (KAFKA-2414) Running kafka-producer-perf-test.sh with " --messages 10000000 --message-size 1000 --new-producer" will get WARN Error in I/O.

[ https://issues.apache.org/jira/browse/KAFKA-2414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2414: --- Summary: Running kafka-producer-perf-test.sh with " --messages 1000 --message-size 1000 --new-producer"

[jira] [Commented] (KAFKA-2414) Running kafka-producer-perf-test.sh with " --messages 10000000 --message-size 1000 --new-producer" will got WARN Error in I/O.

[ https://issues.apache.org/jira/browse/KAFKA-2414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661164#comment-14661164 ] Bo Wang commented on KAFKA-2414: The exception sometimes occurs , how can I fix or avoid t

[jira] [Created] (KAFKA-2414) Running kafka-producer-perf-test.sh with " --messages 10000000 --message-size 1000 --new-producer" will got WARN Error in I/O.

Bo Wang created KAFKA-2414: -- Summary: Running kafka-producer-perf-test.sh with " --messages 1000 --message-size 1000 --new-producer" will got WARN Error in I/O. Key: KAFKA-2414 URL: https://issues.apache.org/jira/b

[jira] [Commented] (KAFKA-1997) Refactor Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661161#comment-14661161 ] Jun Rao commented on KAFKA-1997: [~becket_qin], has this been fixed yet? Thanks, > Refact

[jira] [Comment Edited] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661160#comment-14661160 ] Jason Gustafson edited comment on KAFKA-2413 at 8/7/15 1:20 AM:

[jira] [Commented] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661160#comment-14661160 ] Jason Gustafson commented on KAFKA-2413: I think the issue is in here: {code} p

[jira] [Commented] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661157#comment-14661157 ] Ashish K Singh commented on KAFKA-2413: --- Thanks guys for quick response! Below is a

[jira] [Reopened] (KAFKA-1835) Kafka new producer needs options to make blocking behavior explicit

[ https://issues.apache.org/jira/browse/KAFKA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao reopened KAFKA-1835: > Kafka new producer needs options to make blocking behavior explicit >

[jira] [Resolved] (KAFKA-1835) Kafka new producer needs options to make blocking behavior explicit

[ https://issues.apache.org/jira/browse/KAFKA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1835. Resolution: Duplicate > Kafka new producer needs options to make blocking behavior explicit > --

[jira] [Updated] (KAFKA-1835) Kafka new producer needs options to make blocking behavior explicit

[ https://issues.apache.org/jira/browse/KAFKA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1835: --- Resolution: Fixed Status: Resolved (was: Patch Available) [~smiklosovic], I think this is being addre

[jira] [Commented] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661135#comment-14661135 ] Jason Gustafson commented on KAFKA-2413: [~onurkaraman] I was able to reproduce th

[jira] [Updated] (KAFKA-2351) Brokers are having a problem shutting down correctly

[ https://issues.apache.org/jira/browse/KAFKA-2351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2351: --- Status: In Progress (was: Patch Available) > Brokers are having a problem shutting down correctly > -

[jira] [Updated] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2120: --- Status: In Progress (was: Patch Available) > Add a request timeout to NetworkClient > ---

Re: Review Request 36858: Patch for KAFKA-2120

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/36858/#review94447 --- Thanks for the patch. A few comments below. Also, there seems to be

[jira] [Commented] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661110#comment-14661110 ] Onur Karaman commented on KAFKA-2413: - Couple questions to start things off: 1. What i

[jira] [Commented] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

[ https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661094#comment-14661094 ] Ashish K Singh commented on KAFKA-2413: --- [~hachikuji] thoughts? > New consumer's su

[jira] [Created] (KAFKA-2413) New consumer's subscribe(Topic...) api fails if called more than once

Ashish K Singh created KAFKA-2413: - Summary: New consumer's subscribe(Topic...) api fails if called more than once Key: KAFKA-2413 URL: https://issues.apache.org/jira/browse/KAFKA-2413 Project: Kafka

[jira] [Commented] (KAFKA-2400) Expose heartbeat frequency in new consumer configuration

[ https://issues.apache.org/jira/browse/KAFKA-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660955#comment-14660955 ] Onur Karaman commented on KAFKA-2400: - [~hachikuji]: Yeah the reason behind the decoup

[jira] [Commented] (KAFKA-2400) Expose heartbeat frequency in new consumer configuration

[ https://issues.apache.org/jira/browse/KAFKA-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660950#comment-14660950 ] Jason Gustafson commented on KAFKA-2400: [~onurkaraman], [~guozhang] One related p

[jira] [Resolved] (KAFKA-2340) Add additional unit tests for new consumer Fetcher

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

[jira] [Assigned] (KAFKA-2340) Add additional unit tests for new consumer Fetcher

[ https://issues.apache.org/jira/browse/KAFKA-2340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-2340: Assignee: Jason Gustafson > Add additional unit tests for new consumer Fetcher > --

[GitHub] kafka pull request: KAFKA-2340; improve KafkaConsumer Fetcher test...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/112 --- 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] [Commented] (KAFKA-2340) Add additional unit tests for new consumer Fetcher

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

[jira] [Commented] (KAFKA-2400) Expose heartbeat frequency in new consumer configuration

[ https://issues.apache.org/jira/browse/KAFKA-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660921#comment-14660921 ] Guozhang Wang commented on KAFKA-2400: -- Hey [~onurkaraman], yeah that is indeed an is

[jira] [Updated] (KAFKA-2403) Expose offset commit metadata in new consumer

[ https://issues.apache.org/jira/browse/KAFKA-2403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2403: --- Status: Patch Available (was: Open) > Expose offset commit metadata in new consumer > ---

[jira] [Commented] (KAFKA-2403) Expose offset commit metadata in new consumer

[ https://issues.apache.org/jira/browse/KAFKA-2403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660911#comment-14660911 ] Jason Gustafson commented on KAFKA-2403: No hurry to get this checked in, but I th

[jira] [Commented] (KAFKA-2403) Expose offset commit metadata in new consumer

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

[GitHub] kafka pull request: KAFKA-2403; Add support for commit metadata in...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/119 KAFKA-2403; Add support for commit metadata in KafkaConsumer You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-2403 Altern

[jira] [Comment Edited] (KAFKA-2400) Expose heartbeat frequency in new consumer configuration

[ https://issues.apache.org/jira/browse/KAFKA-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660896#comment-14660896 ] Onur Karaman edited comment on KAFKA-2400 at 8/6/15 10:39 PM: --

[jira] [Commented] (KAFKA-2400) Expose heartbeat frequency in new consumer configuration

[ https://issues.apache.org/jira/browse/KAFKA-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660903#comment-14660903 ] Jason Gustafson commented on KAFKA-2400: [~onurkaraman] The goal of the ticket was

[jira] [Commented] (KAFKA-2400) Expose heartbeat frequency in new consumer configuration

[ https://issues.apache.org/jira/browse/KAFKA-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660896#comment-14660896 ] Onur Karaman commented on KAFKA-2400: - It seems that this change could increase the ch

[jira] [Updated] (KAFKA-2400) Expose heartbeat frequency in new consumer configuration

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

[jira] [Commented] (KAFKA-2400) Expose heartbeat frequency in new consumer configuration

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

[GitHub] kafka pull request: KAFKA-2400; expose heartbeat interval in Kafka...

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

Re: KAFKA-2364 migrate docs from SVN to git

+1 for the same repo. The closer docs can be to code the more accurate they are likely to be. The same way we encourage unit tests for a new feature/patch. Updating the docs can be the same. If we follow Sqoop's process for example, how would small fixes/adjustments/additions to the live documenta

Re: KAFKA-2364 migrate docs from SVN to git

I am +1 on same repo too. I think keeping one git history of code / doc change may actually be beneficial for this approach as well. Guozhang On Thu, Aug 6, 2015 at 9:16 AM, Gwen Shapira wrote: > I prefer same repo for one-commit / lower-barrier benefits. > > Sqoop has the following process, wh

[jira] [Commented] (KAFKA-1893) Allow regex subscriptions in the new consumer

[ https://issues.apache.org/jira/browse/KAFKA-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660717#comment-14660717 ] Jason Gustafson commented on KAFKA-1893: Ditto what [~onurkaraman] said. I think t

[jira] [Commented] (KAFKA-1893) Allow regex subscriptions in the new consumer

[ https://issues.apache.org/jira/browse/KAFKA-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660687#comment-14660687 ] Onur Karaman commented on KAFKA-1893: - I agree with [~singhashish] that we should keep

[jira] [Commented] (KAFKA-2143) Replicas get ahead of leader and fail

[ https://issues.apache.org/jira/browse/KAFKA-2143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660629#comment-14660629 ] Ewen Cheslack-Postava commented on KAFKA-2143: -- [~wushujames] I think one eas

[jira] [Commented] (KAFKA-1893) Allow regex subscriptions in the new consumer

[ https://issues.apache.org/jira/browse/KAFKA-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660584#comment-14660584 ] Ashish K Singh commented on KAFKA-1893: --- Should we support topic and regex subscript

[jira] [Commented] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660405#comment-14660405 ] Jason Gustafson commented on KAFKA-2120: [~becket_qin] That is what I was thinking

[jira] [Comment Edited] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660397#comment-14660397 ] Mayuresh Gharat edited comment on KAFKA-2120 at 8/6/15 5:24 PM:

[jira] [Commented] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660397#comment-14660397 ] Mayuresh Gharat commented on KAFKA-2120: [~becket_qin] yes we can do that. I will

[jira] [Commented] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660375#comment-14660375 ] Jiangjie Qin commented on KAFKA-2120: - [~hachikuji] [~mgharat], the request time is fo

[jira] [Commented] (KAFKA-2351) Brokers are having a problem shutting down correctly

[ https://issues.apache.org/jira/browse/KAFKA-2351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660361#comment-14660361 ] Mayuresh Gharat commented on KAFKA-2351: Thanks [~junrao]. I will see if I can add

[jira] [Comment Edited] (KAFKA-2351) Brokers are having a problem shutting down correctly

[ https://issues.apache.org/jira/browse/KAFKA-2351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660361#comment-14660361 ] Mayuresh Gharat edited comment on KAFKA-2351 at 8/6/15 5:11 PM:

[jira] [Commented] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660329#comment-14660329 ] Jason Gustafson commented on KAFKA-2120: [~mgharat] Sounds reasonable to me. Thank

[jira] [Commented] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660314#comment-14660314 ] Mayuresh Gharat commented on KAFKA-2120: Hi [~jasong35], Cool. So what we can do

[jira] [Commented] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660303#comment-14660303 ] Jason Gustafson commented on KAFKA-2120: [~mgharat] Yeah, that's what I mean. I th

[jira] [Commented] (KAFKA-2397) leave group request

[ https://issues.apache.org/jira/browse/KAFKA-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660279#comment-14660279 ] Jay Kreps commented on KAFKA-2397: -- [~guozhang] Basically "session" would be the concept

[jira] [Commented] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660276#comment-14660276 ] Mayuresh Gharat commented on KAFKA-2120: [~jasong35] I am not too familiar with th

[jira] [Commented] (KAFKA-2397) leave group request

[ https://issues.apache.org/jira/browse/KAFKA-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660269#comment-14660269 ] Jason Gustafson commented on KAFKA-2397: [~jkreps] Yeah, TCP is pretty resilient t

[jira] [Commented] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660242#comment-14660242 ] Glenn Sontheimer commented on KAFKA-2120: - Hello, I am out of the office and will

[jira] [Commented] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660241#comment-14660241 ] Jason Gustafson commented on KAFKA-2120: [~mgharat] It occurred to me that the glo

Re: KAFKA-2364 migrate docs from SVN to git

I prefer same repo for one-commit / lower-barrier benefits. Sqoop has the following process, which decouples documentation changes from website changes: 1. Code github repo contains a doc directory, with the documentation written and maintained in AsciiDoc. Only one version of the documentation,

Re: Review Request 33049: Patch for KAFKA-2084

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33049/#review94412 --- A few more comments. We need to be careful with sensors at the clie

Re: [DISCUSS] Partitioning in Kafka

OK, the general consensus seems to be that more elaborate partitioning functions belong to the scope of Kafka. Could somebody have a look at KAFKA-2092 then? -- Gianmarco On 30 July 2015 at 05:57, Jiangjie Qin wrote: > Just my two cents. I thin

[jira] [Commented] (KAFKA-2364) Improve documentation for contributing to docs

[ https://issues.apache.org/jira/browse/KAFKA-2364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660041#comment-14660041 ] Ben Stopford commented on KAFKA-2364: - Hi Aseem Have you signed up to the mailing lis

[jira] [Work started] (KAFKA-2411) remove usage of BlockingChannel in the broker

[ https://issues.apache.org/jira/browse/KAFKA-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2411 started by Ismael Juma. -- > remove usage of BlockingChannel in the broker > ---

[jira] [Commented] (KAFKA-1835) Kafka new producer needs options to make blocking behavior explicit

[ https://issues.apache.org/jira/browse/KAFKA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14659965#comment-14659965 ] Stefan Miklosovic commented on KAFKA-1835: -- Any progres? It is weird there is no

[jira] [Commented] (KAFKA-2364) Improve documentation for contributing to docs

[ https://issues.apache.org/jira/browse/KAFKA-2364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14659917#comment-14659917 ] Aseem Bansal commented on KAFKA-2364: - How do you reply to and get those emails? > I

Re: Review Request 34641: Patch for KAFKA-2214

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34641/#review94378 --- core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala (li

[jira] [Commented] (KAFKA-2364) Improve documentation for contributing to docs

[ https://issues.apache.org/jira/browse/KAFKA-2364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14659615#comment-14659615 ] Ismael Juma commented on KAFKA-2364: [~anshbansal], there were a couple of responses:

Re: KAFKA-2364 migrate docs from SVN to git

Hi, For reference, here is the previous discussion on moving the website to Git: http://search-hadoop.com/m/uyzND11JliU1E8QU92 People were positive to the idea as Jay said. I would like to see a bit of a discussion around whether the website should be part of the same repo as the code or not. I'