[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=14659525#comment-14659525 ] Guozhang Wang commented on KAFKA-2397: -- [~jkreps] I need to look into the session imp

[jira] [Comment Edited] (KAFKA-2397) leave group request

[ https://issues.apache.org/jira/browse/KAFKA-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14659158#comment-14659158 ] Guozhang Wang edited comment on KAFKA-2397 at 8/6/15 5:35 AM: --

[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=14659503#comment-14659503 ] James Cheng commented on KAFKA-2143: Thanks [~becket_qin]. [~ewencp] sent me that slid

[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=14659500#comment-14659500 ] Aseem Bansal commented on KAFKA-2364: - I did this but didn't get a reply. Are the repl

[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=14659477#comment-14659477 ] Jiangjie Qin commented on KAFKA-2143: - In that case, yes, messages 3000-5000 will be l

[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=14659470#comment-14659470 ] Jay Kreps commented on KAFKA-2397: -- [~guozhang] I haven't thought this through but here i

Re: Review Request 33049: Patch for KAFKA-2084

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33049/#review94333 --- Thanks for the patch. A few comments below. clients/src/main/java/

[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=14659277#comment-14659277 ] James Cheng commented on KAFKA-2143: I'm trying to understand part of [~bugzmanov]'s d

[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=14659275#comment-14659275 ] Jason Gustafson commented on KAFKA-2397: [~jkreps] I think the disconnect approach

[jira] [Commented] (KAFKA-2406) ISR propagation should be throttled to avoid overwhelming controller.

[ https://issues.apache.org/jira/browse/KAFKA-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14659269#comment-14659269 ] Jiangjie Qin commented on KAFKA-2406: - [~junrao], sure. I'm testing the new patch and

Jenkins build is back to normal : Kafka-trunk #573

See

[jira] [Created] (KAFKA-2412) Documentation bug: Add information for key.serializer and value.serializer to New Producer Config sections

Jeremy Fields created KAFKA-2412: Summary: Documentation bug: Add information for key.serializer and value.serializer to New Producer Config sections Key: KAFKA-2412 URL: https://issues.apache.org/jira/browse/KAFK

[jira] [Commented] (KAFKA-2390) Seek() should take a callback.

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

[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=14659235#comment-14659235 ] Jun Rao commented on KAFKA-2351: [~mgharat], sorry the delay. Just replied on RB. > Broke

[GitHub] kafka pull request: KAFKA-2390; Seek() should take a callback

GitHub user lindong28 opened a pull request: https://github.com/apache/kafka/pull/118 KAFKA-2390; Seek() should take a callback You can merge this pull request into a Git repository by running: $ git pull https://github.com/lindong28/kafka KAFKA-2390 Alternatively you can rev

Re: Review Request 36652: Patch for KAFKA-2351

> On July 24, 2015, 5:01 p.m., Mayuresh Gharat wrote: > > core/src/main/scala/kafka/network/SocketServer.scala, line 264 > > > > > > Hi Jun, > > Cleaning up in finally is actually nice. I will make the necessary

[jira] [Commented] (KAFKA-2406) ISR propagation should be throttled to avoid overwhelming controller.

[ https://issues.apache.org/jira/browse/KAFKA-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14659217#comment-14659217 ] Jun Rao commented on KAFKA-2406: [~becket_qin], we can probably do a quick KIP on the conf

[GitHub] kafka pull request: MINOR - Fix typo in ReplicaVerificationTool ou...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/101 --- 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] [Assigned] (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 ] Ismael Juma reassigned KAFKA-2411: -- Assignee: Ismael Juma > remove usage of BlockingChannel in the broker > ---

[GitHub] kafka pull request: MINOR: Fixed javadoc for committed return valu...

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

[GitHub] kafka pull request: MINOR: auto.offset.reset docs not in sync with...

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

[GitHub] kafka pull request: MINOR: ConsumerRecords are organized per topic...

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

[jira] [Commented] (KAFKA-1690) new java producer needs ssl support as a client

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14659188#comment-14659188 ] Ashish K Singh commented on KAFKA-1690: --- Thanks [~junrao]! > new java producer need

[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=14659185#comment-14659185 ] Gwen Shapira commented on KAFKA-2397: - No, SocketServer may be aware of host:port of c

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

[ https://issues.apache.org/jira/browse/KAFKA-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14659184#comment-14659184 ] Jun Rao commented on KAFKA-2411: For AbstractFetcherThread, we could potentially use Netwo

[jira] [Commented] (KAFKA-1690) new java producer needs ssl support as a client

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14659174#comment-14659174 ] Jun Rao commented on KAFKA-1690: [~singhashish], thanks for the reminder. File KAFKA-2411

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

Jun Rao created KAFKA-2411: -- Summary: remove usage of BlockingChannel in the broker Key: KAFKA-2411 URL: https://issues.apache.org/jira/browse/KAFKA-2411 Project: Kafka Issue Type: Sub-task

Build failed in Jenkins: Kafka-trunk #572

See Changes: [junrao] KAFKA-2393: Correctly Handle InvalidTopicException in KafkaApis.getTo��� -- [...truncated 1517 lines...] kafka.api.test.ProducerCompressionTest > testCompression[0] PASSED kafk

[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=14659158#comment-14659158 ] Guozhang Wang commented on KAFKA-2397: -- I once considered letting KafkaApis to handle

[jira] [Commented] (KAFKA-2406) ISR propagation should be throttled to avoid overwhelming controller.

[ https://issues.apache.org/jira/browse/KAFKA-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14659147#comment-14659147 ] Jiangjie Qin commented on KAFKA-2406: - [~ashishujjain] [~junrao], sure, we can make th

[jira] [Updated] (KAFKA-2393) Correctly Handle InvalidTopicException in KafkaApis.getTopicMetadata()

[ https://issues.apache.org/jira/browse/KAFKA-2393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2393: --- Resolution: Fixed Status: Resolved (was: Patch Available) Thanks for the patch. Committed to trunk.

[jira] [Commented] (KAFKA-2393) Correctly Handle InvalidTopicException in KafkaApis.getTopicMetadata()

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

[GitHub] kafka pull request: KAFKA-2393: Correctly Handle InvalidTopicExcep...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/117 --- 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-313) Add JSON/CSV output and looping options to ConsumerGroupCommand

[ https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14659110#comment-14659110 ] Ashish K Singh commented on KAFKA-313: -- Updated reviewboard https://reviews.apache.org

[jira] [Updated] (KAFKA-313) Add JSON/CSV output and looping options to ConsumerGroupCommand

[ https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-313: - Attachment: KAFKA-313_2015-08-05_15:43:00.patch > Add JSON/CSV output and looping options to Consum

Re: Review Request 28096: Patch for KAFKA-313

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/28096/ --- (Updated Aug. 5, 2015, 10:43 p.m.) Review request for kafka, Gwen Shapira, Jare

[jira] [Updated] (KAFKA-313) Add JSON/CSV output and looping options to ConsumerGroupCommand

[ https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-313: - Attachment: KAFKA-313_2015-08-05_15:37:32.patch > Add JSON/CSV output and looping options to Consum

[jira] [Updated] (KAFKA-313) Add JSON/CSV output and looping options to ConsumerGroupCommand

[ https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-313: - Status: Patch Available (was: In Progress) > Add JSON/CSV output and looping options to ConsumerGr

Re: Review Request 28096: Patch for KAFKA-313

> On July 29, 2015, 6:35 p.m., Gwen Shapira wrote: > > core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala, lines 36-39 > > > > > > Shouldn't this be an inner object? since its only visible and used by > > Consu

[jira] [Commented] (KAFKA-313) Add JSON/CSV output and looping options to ConsumerGroupCommand

[ https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14659105#comment-14659105 ] Ashish K Singh commented on KAFKA-313: -- Updated reviewboard https://reviews.apache.org

Re: Review Request 28096: Patch for KAFKA-313

> On July 30, 2015, 2:11 p.m., Ismael Juma wrote: > > core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala, line 45 > > > > > > Do we really need this var or can this be passed as a parameter to the > > relevant

Re: Review Request 28096: Patch for KAFKA-313

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/28096/ --- (Updated Aug. 5, 2015, 10:37 p.m.) Review request for kafka, Gwen Shapira, Jare

[jira] [Created] (KAFKA-2410) Implement "Auto Topic Creation" client side and remove support from Broker side

Grant Henke created KAFKA-2410: -- Summary: Implement "Auto Topic Creation" client side and remove support from Broker side Key: KAFKA-2410 URL: https://issues.apache.org/jira/browse/KAFKA-2410 Project: Ka

[jira] [Commented] (KAFKA-1229) Reload broker config without a restart

[ https://issues.apache.org/jira/browse/KAFKA-1229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14659071#comment-14659071 ] Aditya Auradkar commented on KAFKA-1229: Hey [~vamsi360], We recently did a prett

[jira] [Commented] (KAFKA-1690) new java producer needs ssl support as a client

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14659065#comment-14659065 ] Ashish K Singh commented on KAFKA-1690: --- [~harsha_ch] sure, no issues. Also, do we h

[jira] [Commented] (KAFKA-2406) ISR propagation should be throttled to avoid overwhelming controller.

[ https://issues.apache.org/jira/browse/KAFKA-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14659039#comment-14659039 ] Jun Rao commented on KAFKA-2406: [~becket_qin], the ZK watcher is a one-time watcher. So,

[jira] [Updated] (KAFKA-2393) Correctly Handle InvalidTopicException in KafkaApis.getTopicMetadata()

[ https://issues.apache.org/jira/browse/KAFKA-2393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-2393: --- Fix Version/s: 0.8.3 Status: Patch Available (was: Open) > Correctly Handle InvalidTopicEx

[jira] [Commented] (KAFKA-2393) Correctly Handle InvalidTopicException in KafkaApis.getTopicMetadata()

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

[GitHub] kafka pull request: KAFKA-2393: Correctly Handle InvalidTopicExcep...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/117 KAFKA-2393: Correctly Handle InvalidTopicException in KafkaApis.getTo… …picMetadata() You can merge this pull request into a Git repository by running: $ git pull https://github.com/grant

[jira] [Commented] (KAFKA-2406) ISR propagation should be throttled to avoid overwhelming controller.

[ https://issues.apache.org/jira/browse/KAFKA-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14659007#comment-14659007 ] Jun Rao commented on KAFKA-2406: [~singhashish], yes, ideally we want to propagate isr asa

[jira] [Issue Comment Deleted] (KAFKA-2406) ISR propagation should be throttled to avoid overwhelming controller.

[ https://issues.apache.org/jira/browse/KAFKA-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2406: Comment: was deleted (was: I just tried the WIP patch, no luck. I'll try out the solution we just d

[jira] [Commented] (KAFKA-2406) ISR propagation should be throttled to avoid overwhelming controller.

[ https://issues.apache.org/jira/browse/KAFKA-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14658974#comment-14658974 ] Jiangjie Qin commented on KAFKA-2406: - I just tried the WIP patch, no luck. I'll try o

[jira] [Comment Edited] (KAFKA-2406) ISR propagation should be throttled to avoid overwhelming controller.

[ https://issues.apache.org/jira/browse/KAFKA-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14658968#comment-14658968 ] Jiangjie Qin edited comment on KAFKA-2406 at 8/5/15 9:24 PM: -

[jira] [Commented] (KAFKA-2406) ISR propagation should be throttled to avoid overwhelming controller.

[ https://issues.apache.org/jira/browse/KAFKA-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14658968#comment-14658968 ] Jiangjie Qin commented on KAFKA-2406: - [~junrao], I was thinking to have a sequential

[jira] [Commented] (KAFKA-2406) ISR propagation should be throttled to avoid overwhelming controller.

[ https://issues.apache.org/jira/browse/KAFKA-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14658944#comment-14658944 ] Ashish K Singh commented on KAFKA-2406: --- Makes sense. Can I suggest that we still ke

Re: Review Request 36548: Patch for KAFKA-2336

> On July 17, 2015, 4:26 a.m., Jiangjie Qin wrote: > > Looks good to me. > > Jiangjie Qin wrote: > Actually do we need to talk to Zookeeper every time? Can we read the data > from topic metadata cache directly? > > Gwen Shapira wrote: > Good point, Jiangjie - looks like partitionFor is

[jira] [Commented] (KAFKA-2406) ISR propagation should be throttled to avoid overwhelming controller.

[ https://issues.apache.org/jira/browse/KAFKA-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14658929#comment-14658929 ] Jiangjie Qin commented on KAFKA-2406: - [~ashishujjain], the large number of ISR change

[jira] [Commented] (KAFKA-2406) ISR propagation should be throttled to avoid overwhelming controller.

[ https://issues.apache.org/jira/browse/KAFKA-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14658922#comment-14658922 ] Jun Rao commented on KAFKA-2406: [~becket_qin], are you suggesting not using sequential ZK

[jira] [Commented] (KAFKA-2406) ISR propagation should be throttled to avoid overwhelming controller.

[ https://issues.apache.org/jira/browse/KAFKA-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14658909#comment-14658909 ] Ashish K Singh commented on KAFKA-2406: --- [~junrao], [~becket_qin] it sounds like we

[jira] [Updated] (KAFKA-2409) Have KafkaConsumer.committed() return null when there is no committed offset

[ https://issues.apache.org/jira/browse/KAFKA-2409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2409: --- Issue Type: Sub-task (was: Improvement) Parent: KAFKA-2387 > Have KafkaConsumer.commi

[jira] [Created] (KAFKA-2409) Have KafkaConsumer.committed() return null when there is no committed offset

Jason Gustafson created KAFKA-2409: -- Summary: Have KafkaConsumer.committed() return null when there is no committed offset Key: KAFKA-2409 URL: https://issues.apache.org/jira/browse/KAFKA-2409 Projec

[jira] [Commented] (KAFKA-2406) ISR propagation should be throttled to avoid overwhelming controller.

[ https://issues.apache.org/jira/browse/KAFKA-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14658781#comment-14658781 ] Jiangjie Qin commented on KAFKA-2406: - [~junrao], I'm still doing the test, here is wh

[jira] [Commented] (KAFKA-2401) Fix transient failure of ProducerSendTest.testCloseWithZeroTimeoutFromSenderThread()

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

[jira] [Resolved] (KAFKA-2401) Fix transient failure of ProducerSendTest.testCloseWithZeroTimeoutFromSenderThread()

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

[GitHub] kafka pull request: KAFKA-2401: fix transient failure in ProducerS...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/113 --- 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-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=14658749#comment-14658749 ] Mayuresh Gharat commented on KAFKA-2351: [~sslavic] I think this is different. Tha

[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 ] Jason Gustafson updated KAFKA-2400: --- Reviewer: Guozhang Wang Status: Patch Available (was: Open) > Expose heartbeat frequenc

[jira] [Commented] (KAFKA-2406) ISR propagation should be throttled to avoid overwhelming controller.

[ https://issues.apache.org/jira/browse/KAFKA-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14658685#comment-14658685 ] Jun Rao commented on KAFKA-2406: [~becket_qin], another way to reduce the overhead is to b

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

Geoffrey Anderson created KAFKA-2408: Summary: (new) system tests: ConsoleConsumerService occasionally fails to register consumed message Key: KAFKA-2408 URL: https://issues.apache.org/jira/browse/KAFKA-2408

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

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

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/116 KAFKA-2400; expose heartbeat interval in KafkaConsumer configuration You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-2400

[jira] [Updated] (KAFKA-2407) Only create a log directory when it will be used

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

[jira] [Commented] (KAFKA-2407) Only create a log directory when it will be used

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

[GitHub] kafka pull request: KAFKA-2407: Only create log directory when it ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/115 --- 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] [Updated] (KAFKA-2390) Seek() should take a callback.

[ https://issues.apache.org/jira/browse/KAFKA-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2390: Description: Currently seek is an async call. To have the same interface as other calls like commit(), seek(

Re: Modified the contribution pages in the wiki

Yes, that page is crystal clear that we are using PR only :) Jiangjie (Becket) Qin On Wed, Aug 5, 2015 at 10:56 AM, Gwen Shapira wrote: > The sentence is good, but I think we route new developers to here: > https://cwiki.apache.org/confluence/display/KAFKA/Contributing+Code+Changes > > Can you

[jira] [Updated] (KAFKA-2407) Only create a log directory when it will be used

[ https://issues.apache.org/jira/browse/KAFKA-2407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-2407: --- Status: Patch Available (was: Open) > Only create a log directory when it will be used >

[jira] [Commented] (KAFKA-2407) Only create a log directory when it will be used

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

[GitHub] kafka pull request: KAFKA-2407: Only create log directory when it ...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/115 KAFKA-2407: Only create log directory when it will be used You can merge this pull request into a Git repository by running: $ git pull https://github.com/granthenke/kafka log-fix Alternati

Re: Modified the contribution pages in the wiki

The sentence is good, but I think we route new developers to here: https://cwiki.apache.org/confluence/display/KAFKA/Contributing+Code+Changes Can you check if this page makes it clear that we take PRs and PRs only? Gwen On Wed, Aug 5, 2015 at 10:36 AM, Jiangjie Qin wrote: > Hi Gwen, > > I jus

Re: Modified the contribution pages in the wiki

Hi Gwen, I just added one sentence saying we would prefer PR for new patches. Let me know if you think it is too verbose. Thanks, Jiangjie (Becket) Qin On Wed, Aug 5, 2015 at 8:57 AM, Gwen Shapira wrote: > Completely agree! Thank you for reviewing and improving. > > > > > > On Wed, Aug 5, 201

[jira] [Created] (KAFKA-2407) Only create a log directory when it will be used

Grant Henke created KAFKA-2407: -- Summary: Only create a log directory when it will be used Key: KAFKA-2407 URL: https://issues.apache.org/jira/browse/KAFKA-2407 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-2390) Seek() should take a callback.

[ https://issues.apache.org/jira/browse/KAFKA-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14658550#comment-14658550 ] Dong Lin commented on KAFKA-2390: - [~hachikuji] Yeah we definitely should do it. I will up

[jira] [Commented] (KAFKA-2390) Seek() should take a callback.

[ https://issues.apache.org/jira/browse/KAFKA-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14658548#comment-14658548 ] Jason Gustafson commented on KAFKA-2390: [~lindong] Yeah, that makes sense. Perhap

[jira] [Commented] (KAFKA-2390) Seek() should take a callback.

[ https://issues.apache.org/jira/browse/KAFKA-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14658541#comment-14658541 ] Dong Lin commented on KAFKA-2390: - [~hachikuji] Per discussion with [~becket_qin], the mot

Re: New Consumer API and Range Consumption with Fail-over

Hi Jason, Thanks for info. I will implement (by end of next week) what you have proposed. If I encounter any issue, I will let you know. Indeed, adding new API would be uphill battle. I did follow email chain "Re: Kafka Consumer thoughts". Thanks, Bhavesh On Wed, Aug 5, 2015 at 10:03 AM, J

[jira] [Commented] (KAFKA-2390) Seek() should take a callback.

[ https://issues.apache.org/jira/browse/KAFKA-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14658534#comment-14658534 ] Jason Gustafson commented on KAFKA-2390: [~becket_qin] I can see where this might

[jira] [Commented] (KAFKA-2406) ISR propagation should be throttled to avoid overwhelming controller.

[ https://issues.apache.org/jira/browse/KAFKA-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14658531#comment-14658531 ] Jiangjie Qin commented on KAFKA-2406: - Hi [~junrao], I'm doing the test right now. Thi

Re: New Consumer API and Range Consumption with Fail-over

Hey Bhavesh, I think your use case can be handled with the new consumer API in roughly the manner I suggested previously. It might be a little easier if we added the ability to set the end offset for consumption. Perhaps something like this: // stop consumption from the partition when offset is r

Re: JIRA KAFKA-1716

Looking at the stacktrace and I am wondering if it has been solved in KAFKA-2241. Thanks, Jiangjie (Becket) Qin On Wed, Aug 5, 2015 at 8:00 AM, Chris Barlock wrote: > While I don't have a patch to contribute today, per the "Nag us" note > here: > > http://kafka.apache.org/contributing.html > >

[jira] [Commented] (KAFKA-2405) KafkaHealthCheck kills the JVM in handleSessionEstablishmentError

[ https://issues.apache.org/jira/browse/KAFKA-2405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14658510#comment-14658510 ] Gwen Shapira commented on KAFKA-2405: - It is supported to create KafkaServer by instan

Re: Modified the contribution pages in the wiki

Completely agree! Thank you for reviewing and improving. On Wed, Aug 5, 2015 at 7:22 AM, Ismael Juma wrote: > Hi Gwen, > > I moved some text from > > https://cwiki.apache.org/confluence/display/KAFKA/Patch+submission+and+review > to https://cwiki.apache.org/confluence/display/KAFKA/Patch+Rev

[jira] [Commented] (KAFKA-2406) ISR propagation should be throttled to avoid overwhelming controller.

[ https://issues.apache.org/jira/browse/KAFKA-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14658417#comment-14658417 ] Jun Rao commented on KAFKA-2406: [~becket_qin], thanks for the patch. Have you tested the

Re: Review Request 34641: Patch for KAFKA-2214

> On July 17, 2015, 5:03 a.m., Gwen Shapira wrote: > > Just realized that verifyAssigment runs on a Map of and > > originally printed status for each partition (some can succeed, fail or be > > in-progress). > > > > We need to return a single error code. In the existing code, we return 0 if

[jira] [Commented] (KAFKA-2214) kafka-reassign-partitions.sh --verify should return non-zero exit codes when reassignment is not completed yet

[ https://issues.apache.org/jira/browse/KAFKA-2214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14658357#comment-14658357 ] Manikumar Reddy commented on KAFKA-2214: Updated reviewboard https://reviews.apach

[jira] [Updated] (KAFKA-2214) kafka-reassign-partitions.sh --verify should return non-zero exit codes when reassignment is not completed yet

[ https://issues.apache.org/jira/browse/KAFKA-2214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2214: --- Status: Patch Available (was: In Progress) > kafka-reassign-partitions.sh --verify should ret

Re: Review Request 34641: Patch for KAFKA-2214

> On July 21, 2015, 1:50 p.m., Ismael Juma wrote: > > Thanks for the suggestions. - Manikumar Reddy --- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34641/#review92403

[jira] [Updated] (KAFKA-2214) kafka-reassign-partitions.sh --verify should return non-zero exit codes when reassignment is not completed yet

[ https://issues.apache.org/jira/browse/KAFKA-2214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2214: --- Attachment: KAFKA-2214_2015-08-05_20:47:17.patch > kafka-reassign-partitions.sh --verify shoul

Re: Review Request 34641: Patch for KAFKA-2214

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34641/ --- (Updated Aug. 5, 2015, 3:19 p.m.) Review request for kafka. Bugs: KAFKA-2214

JIRA KAFKA-1716

While I don't have a patch to contribute today, per the "Nag us" note here: http://kafka.apache.org/contributing.html I'm wondering if we could get some attention to https://issues.apache.org/jira/browse/KAFKA-1716 We recently upgraded to Kafka 0.8.2.1 and hit a deadlock every time we shutdo

  1   2   >