[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-tabpanelfocusedCommentId=14660405#comment-14660405 ] Jason Gustafson commented on KAFKA-2120: [~becket_qin] That is what I was thinking

[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-tabpanelfocusedCommentId=14654323#comment-14654323 ] Jason Gustafson commented on KAFKA-2403: [~becket_qin] Done. I went ahead and

[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: --- Issue Type: Sub-task (was: Improvement) Parent: KAFKA-2387 Expose heartbeat

[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: --- Issue Type: Sub-task (was: Improvement) Parent: KAFKA-2387 Expose offset commit

[jira] [Assigned] (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 reassigned KAFKA-2403: -- Assignee: Jason Gustafson Expose offset commit metadata in new consumer

[jira] [Commented] (KAFKA-2388) subscribe(topic)/unsubscribe(topic) should either take a callback to allow user to handle exceptions or it should be synchronous.

[ https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695608#comment-14695608 ] Jason Gustafson commented on KAFKA-2388: [~onurkaraman] Have you had a chance to

[jira] [Assigned] (KAFKA-2274) Add integration test for consumer coordinator

[ https://issues.apache.org/jira/browse/KAFKA-2274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2274: -- Assignee: Jason Gustafson Add integration test for consumer coordinator

[jira] [Commented] (KAFKA-2388) subscribe(topic)/unsubscribe(topic) should either take a callback to allow user to handle exceptions or it should be synchronous.

[ https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14695877#comment-14695877 ] Jason Gustafson commented on KAFKA-2388: [~onurkaraman] I'll take a shot at it. If

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

[ https://issues.apache.org/jira/browse/KAFKA-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14696351#comment-14696351 ] Jason Gustafson commented on KAFKA-2397: [~ewencp] The only case I can come up

[jira] [Commented] (KAFKA-2388) subscribe(topic)/unsubscribe(topic) should either take a callback to allow user to handle exceptions or it should be synchronous.

[ https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697692#comment-14697692 ] Jason Gustafson commented on KAFKA-2388: [~onurkaraman] I submitted a WIP patch

[jira] [Reopened] (KAFKA-1782) Junit3 Misusage

[ https://issues.apache.org/jira/browse/KAFKA-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reopened KAFKA-1782: It looks like this patch broke some of the tests (e.g. ConsumerTest). We probably need to go

[jira] [Assigned] (KAFKA-2388) subscribe(topic)/unsubscribe(topic) should either take a callback to allow user to handle exceptions or it should be synchronous.

[ https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2388: -- Assignee: Jason Gustafson (was: Onur Karaman) subscribe(topic)/unsubscribe(topic)

[jira] [Work started] (KAFKA-2388) subscribe(topic)/unsubscribe(topic) should either take a callback to allow user to handle exceptions or it should be synchronous.

[ https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2388 started by Jason Gustafson. -- subscribe(topic)/unsubscribe(topic) should either take a callback to allow

[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-tabpanelfocusedCommentId=14660241#comment-14660241 ] Jason Gustafson commented on KAFKA-2120: [~mgharat] It occurred to me that the

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

[ https://issues.apache.org/jira/browse/KAFKA-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14659275#comment-14659275 ] Jason Gustafson commented on KAFKA-2397: [~jkreps] I think the disconnect approach

[jira] [Updated] (KAFKA-2350) Add KafkaConsumer pause capability

[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2350: --- Description: There are some use cases in stream processing where it is helpful to be able to

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14643442#comment-14643442 ] Jason Gustafson commented on KAFKA-2350: [~becket_qin] I think that we're on the

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14643349#comment-14643349 ] Jason Gustafson commented on KAFKA-2350: There's one interesting implementation

[jira] [Comment Edited] (KAFKA-2350) Add KafkaConsumer pause capability

[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14637187#comment-14637187 ] Jason Gustafson edited comment on KAFKA-2350 at 7/22/15 5:01 PM:

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14637187#comment-14637187 ] Jason Gustafson commented on KAFKA-2350: [~becket_qin] [~jkreps] Currently

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639796#comment-14639796 ] Jason Gustafson commented on KAFKA-2350: I agree that even if we use

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639424#comment-14639424 ] Jason Gustafson commented on KAFKA-2350: [~becket_qin] It would help if you would

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636105#comment-14636105 ] Jason Gustafson commented on KAFKA-2350: Hey [~becket_qin], thanks for the

[jira] [Updated] (KAFKA-2342) KafkaConsumer rebalance with in-flight fetch can cause invalid position

[ https://issues.apache.org/jira/browse/KAFKA-2342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2342: --- Summary: KafkaConsumer rebalance with in-flight fetch can cause invalid position (was:

[jira] [Updated] (KAFKA-2342) transient unit test failure in testConsumptionWithBrokerFailures

[ https://issues.apache.org/jira/browse/KAFKA-2342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2342: --- Description: If a rebalance occurs with an in-flight fetch, the new KafkaConsumer can end up

[jira] [Commented] (KAFKA-2092) New partitioning for better load balancing

[ https://issues.apache.org/jira/browse/KAFKA-2092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636353#comment-14636353 ] Jason Gustafson commented on KAFKA-2092: [~azaroth], I'm actually not sure that

[jira] [Commented] (KAFKA-2055) ConsumerBounceTest.testSeekAndCommitWithBrokerFailures transient failure

[ https://issues.apache.org/jira/browse/KAFKA-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14641024#comment-14641024 ] Jason Gustafson commented on KAFKA-2055: [~lvfangmin] Looks reasonable to me. Want

[jira] [Commented] (KAFKA-2055) ConsumerBounceTest.testSeekAndCommitWithBrokerFailures transient failure

[ https://issues.apache.org/jira/browse/KAFKA-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14640806#comment-14640806 ] Jason Gustafson commented on KAFKA-2055: [~lvfangmin] I'm going to go ahead and

[jira] [Commented] (KAFKA-2055) ConsumerBounceTest.testSeekAndCommitWithBrokerFailures transient failure

[ https://issues.apache.org/jira/browse/KAFKA-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14640841#comment-14640841 ] Jason Gustafson commented on KAFKA-2055: [~lvfangmin] Sure, no problem.

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14637753#comment-14637753 ] Jason Gustafson commented on KAFKA-2350: [~jkreps] This is a little unrelated to

[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-tabpanelfocusedCommentId=14638028#comment-14638028 ] Jason Gustafson commented on KAFKA-1893: [~singhashish] Sure, no problem. Allow

[jira] [Commented] (KAFKA-2123) Make new consumer offset commit API use callback + future

[ https://issues.apache.org/jira/browse/KAFKA-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14626987#comment-14626987 ] Jason Gustafson commented on KAFKA-2123: Updated reviewboard

[jira] [Updated] (KAFKA-2123) Make new consumer offset commit API use callback + future

[ https://issues.apache.org/jira/browse/KAFKA-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2123: --- Attachment: KAFKA-2123_2015-07-14_13:20:25.patch Make new consumer offset commit API use

[jira] [Commented] (KAFKA-2092) New partitioning for better load balancing

[ https://issues.apache.org/jira/browse/KAFKA-2092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627325#comment-14627325 ] Jason Gustafson commented on KAFKA-2092: [~azaroth], thanks for the update. I

[jira] [Commented] (KAFKA-2123) Make new consumer offset commit API use callback + future

[ https://issues.apache.org/jira/browse/KAFKA-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627383#comment-14627383 ] Jason Gustafson commented on KAFKA-2123: Updated reviewboard

[jira] [Updated] (KAFKA-2123) Make new consumer offset commit API use callback + future

[ https://issues.apache.org/jira/browse/KAFKA-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2123: --- Attachment: KAFKA-2123_2015-07-14_18:21:38.patch Make new consumer offset commit API use

[jira] [Commented] (KAFKA-2335) Javadoc for Consumer says that it's thread-safe

[ https://issues.apache.org/jira/browse/KAFKA-2335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14628377#comment-14628377 ] Jason Gustafson commented on KAFKA-2335: Woops, sorry about that [~eribeiro]. Can

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

Jason Gustafson created KAFKA-2340: -- Summary: Add additional unit tests for new consumer Fetcher Key: KAFKA-2340 URL: https://issues.apache.org/jira/browse/KAFKA-2340 Project: Kafka Issue

[jira] [Commented] (KAFKA-2335) Javadoc for Consumer says that it's thread-safe

[ https://issues.apache.org/jira/browse/KAFKA-2335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629007#comment-14629007 ] Jason Gustafson commented on KAFKA-2335: [~eribeiro], I created KAFKA-2340 just

[jira] [Created] (KAFKA-2343) Clarify KafkaConsumer.poll rebalance behavior

Jason Gustafson created KAFKA-2343: -- Summary: Clarify KafkaConsumer.poll rebalance behavior Key: KAFKA-2343 URL: https://issues.apache.org/jira/browse/KAFKA-2343 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-2343) Clarify KafkaConsumer.poll rebalance behavior

[ https://issues.apache.org/jira/browse/KAFKA-2343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2343: --- Description: The current javadoc for KafkaConsumer.poll says the following: {code} *

[jira] [Assigned] (KAFKA-2342) transient unit test failure in testConsumptionWithBrokerFailures

[ https://issues.apache.org/jira/browse/KAFKA-2342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2342: -- Assignee: Jason Gustafson transient unit test failure in

[jira] [Commented] (KAFKA-2077) Add ability to specify a TopicPicker class for KafkaLog4jApender

[ https://issues.apache.org/jira/browse/KAFKA-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14624895#comment-14624895 ] Jason Gustafson commented on KAFKA-2077: [~benoyantony], I think

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

[ https://issues.apache.org/jira/browse/KAFKA-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-1893: -- Assignee: Jason Gustafson Allow regex subscriptions in the new consumer

[jira] [Commented] (KAFKA-2275) Add a ListTopics() API to the new consumer

[ https://issues.apache.org/jira/browse/KAFKA-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14625460#comment-14625460 ] Jason Gustafson commented on KAFKA-2275: [~singhashish], [~onurkaraman], one of

[jira] [Commented] (KAFKA-2123) Make new consumer offset commit API use callback + future

[ https://issues.apache.org/jira/browse/KAFKA-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14625677#comment-14625677 ] Jason Gustafson commented on KAFKA-2123: Updated reviewboard

[jira] [Updated] (KAFKA-2123) Make new consumer offset commit API use callback + future

[ https://issues.apache.org/jira/browse/KAFKA-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2123: --- Attachment: KAFKA-2123_2015-07-13_18:45:08.patch Make new consumer offset commit API use

[jira] [Created] (KAFKA-2350) Add KafkaConsumer pause capability

Jason Gustafson created KAFKA-2350: -- Summary: Add KafkaConsumer pause capability Key: KAFKA-2350 URL: https://issues.apache.org/jira/browse/KAFKA-2350 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634124#comment-14634124 ] Jason Gustafson commented on KAFKA-2350: Sure, I just meant that if you fail to

[jira] [Updated] (KAFKA-2350) Add KafkaConsumer pause capability

[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2350: --- Description: There are some use cases in stream processing where it is helpful to be able to

[jira] [Commented] (KAFKA-2275) Add a ListTopics() API to the new consumer

[ https://issues.apache.org/jira/browse/KAFKA-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634151#comment-14634151 ] Jason Gustafson commented on KAFKA-2275: [~singhashish], thanks for the response.

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634169#comment-14634169 ] Jason Gustafson commented on KAFKA-2350: There will probably be a large number of

[jira] [Commented] (KAFKA-2342) transient unit test failure in testConsumptionWithBrokerFailures

[ https://issues.apache.org/jira/browse/KAFKA-2342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634274#comment-14634274 ] Jason Gustafson commented on KAFKA-2342: [~junrao], I found a case where a

[jira] [Comment Edited] (KAFKA-2350) Add KafkaConsumer pause capability

[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634294#comment-14634294 ] Jason Gustafson edited comment on KAFKA-2350 at 7/20/15 11:49 PM:

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634294#comment-14634294 ] Jason Gustafson commented on KAFKA-2350: I don't see why not. In that case, I

[jira] [Commented] (KAFKA-2275) Add a ListTopics() API to the new consumer

[ https://issues.apache.org/jira/browse/KAFKA-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14628320#comment-14628320 ] Jason Gustafson commented on KAFKA-2275: Hey [~onurkaraman], I think that seems

[jira] [Assigned] (KAFKA-2335) Javadoc for Consumer says that it's thread-safe

[ https://issues.apache.org/jira/browse/KAFKA-2335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2335: -- Assignee: Jason Gustafson Javadoc for Consumer says that it's thread-safe

[jira] [Commented] (KAFKA-2335) Javadoc for Consumer says that it's thread-safe

[ https://issues.apache.org/jira/browse/KAFKA-2335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14628335#comment-14628335 ] Jason Gustafson commented on KAFKA-2335: Yep, my bad. I went ahead and assigned

[jira] [Created] (KAFKA-2464) Client-side assignment and group generalization

Jason Gustafson created KAFKA-2464: -- Summary: Client-side assignment and group generalization Key: KAFKA-2464 URL: https://issues.apache.org/jira/browse/KAFKA-2464 Project: Kafka Issue

[jira] [Created] (KAFKA-2695) Handle null string/bytes protocol primitives

Jason Gustafson created KAFKA-2695: -- Summary: Handle null string/bytes protocol primitives Key: KAFKA-2695 URL: https://issues.apache.org/jira/browse/KAFKA-2695 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-2691) Improve handling of authorization failure during metadata refresh

[ https://issues.apache.org/jira/browse/KAFKA-2691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14978605#comment-14978605 ] Jason Gustafson commented on KAFKA-2691: [~ijuma] To clarify slightly, the indefinite blocking for

[jira] [Assigned] (KAFKA-2691) Improve handling of authorization failure during metadata refresh

[ https://issues.apache.org/jira/browse/KAFKA-2691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2691: -- Assignee: Jason Gustafson > Improve handling of authorization failure during metadata

[jira] [Commented] (KAFKA-2687) Allow GroupMetadataRequest to return member metadata when received by group coordinator

[ https://issues.apache.org/jira/browse/KAFKA-2687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14981400#comment-14981400 ] Jason Gustafson commented on KAFKA-2687: [~junrao] Sounds good. That's exactly what I implemented

[jira] [Commented] (KAFKA-2674) ConsumerRebalanceListener.onPartitionsRevoked() is not called on consumer close

[ https://issues.apache.org/jira/browse/KAFKA-2674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14979819#comment-14979819 ] Jason Gustafson commented on KAFKA-2674: [~guozhang] In the context of rebalancing, I think the

[jira] [Created] (KAFKA-2687) Allow GroupMetadataRequest to return member metadata when received by group coordinator

Jason Gustafson created KAFKA-2687: -- Summary: Allow GroupMetadataRequest to return member metadata when received by group coordinator Key: KAFKA-2687 URL: https://issues.apache.org/jira/browse/KAFKA-2687

[jira] [Commented] (KAFKA-2687) Allow GroupMetadataRequest to return member metadata when received by group coordinator

[ https://issues.apache.org/jira/browse/KAFKA-2687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14971770#comment-14971770 ] Jason Gustafson commented on KAFKA-2687: [~gwenshap] That's an interesting idea. I wonder if there

[jira] [Commented] (KAFKA-2687) Allow GroupMetadataRequest to return member metadata when received by group coordinator

[ https://issues.apache.org/jira/browse/KAFKA-2687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14971660#comment-14971660 ] Jason Gustafson commented on KAFKA-2687: [~junrao] [~guozhang] I can write up a KIP for this if

[jira] [Assigned] (KAFKA-2674) ConsumerRebalanceListener.onPartitionsRevoked() is not called on consumer close

[ https://issues.apache.org/jira/browse/KAFKA-2674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2674: -- Assignee: Jason Gustafson (was: Neha Narkhede) >

[jira] [Commented] (KAFKA-2674) ConsumerRebalanceListener.onPartitionsRevoked() is not called on consumer close

[ https://issues.apache.org/jira/browse/KAFKA-2674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14974770#comment-14974770 ] Jason Gustafson commented on KAFKA-2674: [~becket_qin] [~guozhang] What would you guys think of

[jira] [Resolved] (KAFKA-2230) Add a wakeup() call to the new consumer

[ https://issues.apache.org/jira/browse/KAFKA-2230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2230. Resolution: Fixed This was added in KAFKA-2168. > Add a wakeup() call to the new consumer

[jira] [Created] (KAFKA-2683) Ensure wakeup exceptions are propagated to user in new consumer

Jason Gustafson created KAFKA-2683: -- Summary: Ensure wakeup exceptions are propagated to user in new consumer Key: KAFKA-2683 URL: https://issues.apache.org/jira/browse/KAFKA-2683 Project: Kafka

[jira] [Commented] (KAFKA-2674) ConsumerRebalanceListener.onPartitionsRevoked() is not called on consumer close

[ https://issues.apache.org/jira/browse/KAFKA-2674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14968420#comment-14968420 ] Jason Gustafson commented on KAFKA-2674: I agree with [~becket_qin] that this is probably not a

[jira] [Assigned] (KAFKA-2795) potential NPE in GroupMetadataManager

[ https://issues.apache.org/jira/browse/KAFKA-2795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2795: -- Assignee: Jason Gustafson (was: Guozhang Wang) > potential NPE in

[jira] [Commented] (KAFKA-2795) potential NPE in GroupMetadataManager

[ https://issues.apache.org/jira/browse/KAFKA-2795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14999181#comment-14999181 ] Jason Gustafson commented on KAFKA-2795: Nice catch. Seems like we need to use the result of

[jira] [Commented] (KAFKA-2747) Message loss if mirror maker is killed with hard kill and then restarted

[ https://issues.apache.org/jira/browse/KAFKA-2747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14997108#comment-14997108 ] Jason Gustafson commented on KAFKA-2747: It would also be helpful to add some logging to

[jira] [Commented] (KAFKA-2674) ConsumerRebalanceListener.onPartitionsRevoked() is not called on consumer close

[ https://issues.apache.org/jira/browse/KAFKA-2674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14997155#comment-14997155 ] Jason Gustafson commented on KAFKA-2674: [~guozhang] [~becket_qin] I added a commit to clarify the

[jira] [Commented] (KAFKA-2822) DescribeConsumerGroup now returns empty list for non-existent group, it used to throw IllegalArgumentException

[ https://issues.apache.org/jira/browse/KAFKA-2822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15002799#comment-15002799 ] Jason Gustafson commented on KAFKA-2822: [~singhashish] Thanks for catching this. I think it's a

[jira] [Commented] (KAFKA-2500) Make logEndOffset available in the 0.8.3 Consumer

[ https://issues.apache.org/jira/browse/KAFKA-2500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15004454#comment-15004454 ] Jason Gustafson commented on KAFKA-2500: [~willf] Apologies for the lack of progress on this

[jira] [Commented] (KAFKA-2500) Make logEndOffset available in the 0.8.3 Consumer

[ https://issues.apache.org/jira/browse/KAFKA-2500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15004707#comment-15004707 ] Jason Gustafson commented on KAFKA-2500: [~wushujames] Yeah, that's right. It uses the high

[jira] [Created] (KAFKA-2840) Support security in kafka-consumer-groups.sh

Jason Gustafson created KAFKA-2840: -- Summary: Support security in kafka-consumer-groups.sh Key: KAFKA-2840 URL: https://issues.apache.org/jira/browse/KAFKA-2840 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-2840) Support security in kafka-consumer-groups.sh

[ https://issues.apache.org/jira/browse/KAFKA-2840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2840. Resolution: Duplicate > Support security in kafka-consumer-groups.sh >

[jira] [Commented] (KAFKA-2841) Group metadata cache loading is not safe when reloading a partition

[ https://issues.apache.org/jira/browse/KAFKA-2841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15005174#comment-15005174 ] Jason Gustafson commented on KAFKA-2841: [~guozhang] Yeah, I think that addresses the major issue,

[jira] [Commented] (KAFKA-2841) Group metadata cache loading is not safe when reloading a partition

[ https://issues.apache.org/jira/browse/KAFKA-2841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15007059#comment-15007059 ] Jason Gustafson commented on KAFKA-2841: [~junrao] That is correct. The problem is that the group

[jira] [Created] (KAFKA-2821) Deadlock in group metadata persistence callback

Jason Gustafson created KAFKA-2821: -- Summary: Deadlock in group metadata persistence callback Key: KAFKA-2821 URL: https://issues.apache.org/jira/browse/KAFKA-2821 Project: Kafka Issue

[jira] [Assigned] (KAFKA-2805) RecordAccumulator request timeout not enforced when all brokers are gone

[ https://issues.apache.org/jira/browse/KAFKA-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2805: -- Assignee: Jason Gustafson (was: Mayuresh Gharat) > RecordAccumulator request timeout

[jira] [Commented] (KAFKA-2805) RecordAccumulator request timeout not enforced when all brokers are gone

[ https://issues.apache.org/jira/browse/KAFKA-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15001004#comment-15001004 ] Jason Gustafson commented on KAFKA-2805: Went ahead and assigned to myself to try and unblock the

[jira] [Updated] (KAFKA-2805) RecordAccumulator request timeout not enforced when all brokers are gone

[ https://issues.apache.org/jira/browse/KAFKA-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2805: --- Assignee: Mayuresh Gharat (was: Jason Gustafson) > RecordAccumulator request timeout not

[jira] [Commented] (KAFKA-2805) RecordAccumulator request timeout not enforced when all brokers are gone

[ https://issues.apache.org/jira/browse/KAFKA-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15001040#comment-15001040 ] Jason Gustafson commented on KAFKA-2805: Works for me. I'll assign back to you. >

[jira] [Created] (KAFKA-2812) Enhance new consumer integration test coverage

Jason Gustafson created KAFKA-2812: -- Summary: Enhance new consumer integration test coverage Key: KAFKA-2812 URL: https://issues.apache.org/jira/browse/KAFKA-2812 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-2805) RecordAccumulator request timeout only enforced if partition leader is unknown

Jason Gustafson created KAFKA-2805: -- Summary: RecordAccumulator request timeout only enforced if partition leader is unknown Key: KAFKA-2805 URL: https://issues.apache.org/jira/browse/KAFKA-2805

[jira] [Commented] (KAFKA-2805) RecordAccumulator request timeout only enforced if partition leader is unknown

[ https://issues.apache.org/jira/browse/KAFKA-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14999792#comment-14999792 ] Jason Gustafson commented on KAFKA-2805: [~mgharat] [~becket_qin] Do you have any thoughts? >

[jira] [Commented] (KAFKA-2805) RecordAccumulator request timeout only enforced if partition leader is unknown

[ https://issues.apache.org/jira/browse/KAFKA-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14999858#comment-14999858 ] Jason Gustafson commented on KAFKA-2805: I was able to reproduce this following the steps from

[jira] [Commented] (KAFKA-2805) RecordAccumulator request timeout only enforced if partition leader is unknown

[ https://issues.apache.org/jira/browse/KAFKA-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1413#comment-1413 ] Jason Gustafson commented on KAFKA-2805: [~mgharat] I was on trunk when I reproduced the problem.

[jira] [Updated] (KAFKA-2805) RecordAccumulator request timeout not enforced when all brokers are gone

[ https://issues.apache.org/jira/browse/KAFKA-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2805: --- Summary: RecordAccumulator request timeout not enforced when all brokers are gone (was:

[jira] [Updated] (KAFKA-2805) RecordAccumulator request timeout only enforced if partition leader is unknown

[ https://issues.apache.org/jira/browse/KAFKA-2805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2805: --- Description: When no brokers are left in the cluster, the producer seems not to enforce the

[jira] [Updated] (KAFKA-2691) Improve handling of authorization failure during metadata refresh

[ https://issues.apache.org/jira/browse/KAFKA-2691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2691: --- Priority: Blocker (was: Major) > Improve handling of authorization failure during metadata

[jira] [Created] (KAFKA-2723) Standardize new consumer exceptions

Jason Gustafson created KAFKA-2723: -- Summary: Standardize new consumer exceptions Key: KAFKA-2723 URL: https://issues.apache.org/jira/browse/KAFKA-2723 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-2697) add leave group logic to the consumer

[ https://issues.apache.org/jira/browse/KAFKA-2697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2697: -- Assignee: Jason Gustafson (was: Onur Karaman) > add leave group logic to the consumer

[jira] [Commented] (KAFKA-2697) add leave group logic to the consumer

[ https://issues.apache.org/jira/browse/KAFKA-2697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14988276#comment-14988276 ] Jason Gustafson commented on KAFKA-2697: [~onurkaraman] Ah, didn't see your comment from

[jira] [Created] (KAFKA-2753) Improve SyncGroup error handling in AbstractCoordinator

Jason Gustafson created KAFKA-2753: -- Summary: Improve SyncGroup error handling in AbstractCoordinator Key: KAFKA-2753 URL: https://issues.apache.org/jira/browse/KAFKA-2753 Project: Kafka

<    1   2   3   4   5   6   7   8   9   10   >